python-3.x - 非同期ルート内から zmq 応答を正しく待機する方法

Question

ルート内からの ZMQ メッセージ応答を待機しようとしていますが、次のエラーが発生します。

RuntimeError: Task got bad yield: <zmq.eventloop.future._TornadoFuture object at 0x7f74f4143c88>

次のコードは、ApiStar のフレームワークに対してコーディングされた API の以前のバージョンで動作しましたが、現在 Starlette に移行することを決定しました。以下のコードはasync def関数に含まれています。

import zmq
from zmq.eventloop.future import Context
import threading
zmq_context = zmq.eventloop.future.Context()
mysocket = zmq_context.socket(zmq.SUB)

mysocket.connect(f"tcp://{DB_HOST}:{DEFAULT_ZMQ_PORT}")

topicstring = 'niOSGOV6eAyUKOOVdXm0CA=='
topicfilter=bytes(topicstring, 'utf-8').decode()
mysocket.setsockopt_string(zmq.SUBSCRIBE, topicfilter)

all_responses = await mysocket.recv_multipart(flags=0, copy=True, track=False)

ご協力ありがとうございます。