how to handle the http stream data without using callback but based on coroutine?

[Ming-Lyu]

            dpm_request = tornado.httpclient.HTTPRequest(
                    url=self.model_url,
                    method="POST",
                    body=data,
                    request_timeout=0,  # Set the timeout value as per your needs
                    # streaming_callback=self.handle_stream, # stream callback
            )
            

is there any way to handle the streaming_callback in a coroutine instead?

[bdarnell]

Not directly. What I'd do if I wanted to use coroutines as much as possible is use a streaming_callback that just writes each chunk to an asyncio.Queue and then have another coroutine that consumes that queue.

Duplicate of #2209.