与 Tornado TCPClient 和 TCPServer 异步

Question

我无法让 TCPClient 和 TCPServer 进入 Tornado。

我有以下服务器代码：

from tornado import gen
from tornado.ioloop import IOLoop
from tornado.iostream import IOStream, StreamClosedError
from tornado.tcpclient import TCPClient
from tornado.tcpserver import TCPServer
from tornado.platform.asyncio import to_tornado_future, to_asyncio_future


class MyServer(TCPServer):

    async def handle_stream(self, stream, address):
        try:
            while True:
               encoded="***".encode()
               msg= await stream.read_until(encoded)
               print(msg)

        except StreamClosedError:
            print("connection error")

server = MyServer()
server.listen(10000)
IOLoop.current().start()

以及以下客户端代码：

from tornado import gen
from tornado.ioloop import IOLoop
from tornado.iostream import IOStream, StreamClosedError
from tornado.tcpclient import TCPClient
from tornado.platform.asyncio import to_tornado_future, to_asyncio_future
tcp_client = TCPClient()


async def client():
    while True:
        try:
            stream = await  tcp_client.connect('localhost', 10000)

            # Set TCP_NODELAY / disable Nagle's Algorithm.
            stream.set_nodelay(True)

            while True:
                msg ="hello ***"
                await  stream.write(msg.encode())
                await gen.sleep(5)

        except StreamClosedError as exc:
            print("error connecting")

loop = IOLoop.current()
loop.spawn_callback(client)
loop.start()

我一直在服务器端收到一个警告，提示从未等待过 handle_stream：

/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/site-packages/tornado-4.4.2-py3.5-macosx-10.6-intel.egg/tornado/netutil.py:272: RuntimeWarning: coroutine 'MyServer.handle_stream' was never awaited
  callback(connection, address)
ERROR:tornado.application:Error in connection callback
Traceback (most recent call last):
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/site-packages/tornado-4.4.2-py3.5-macosx-10.6-intel.egg/tornado/tcpserver.py", line 276, in _handle_connection
    self.io_loop.add_future(future, lambda f: f.result())
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/site-packages/tornado-4.4.2-py3.5-macosx-10.6-intel.egg/tornado/ioloop.py", line 593, in add_future

谁能告诉我我做错了什么以及如何使用 async 和 await 让它工作。

这与杰西友好回答的以下问题有关：

Tornado TCP Server / Client process communication

我试图让他的代码与 async 和 await 一起工作，但是遇到了同样的问题....如果我将上面的代码更改为使用 yield 和 coroutines 它可以工作...

Answer 1

我看到了问题，将在此处修复：github.com/tornadoweb/tornado/pull/1906 同时我认为handle_stream 不能是本机协程，至少不是以任何方便的方式。