Python asyncio: доходность не использовалась с будущим?

Я пытаюсь использовать asyncio для создания асинхронной настройки клиент/сервер.

По какой-то причине я получаю AssertionError: yield from wasn't used with future при запуске клиента.

Поиск этой ошибки не сильно увеличился.
Что означает эта ошибка и что ее вызывает?

#!/usr/bin/env python3

import asyncio
import pickle
import uuid

port = 9999

class ClientProtocol(asyncio.Protocol):
    def __init__(self, loop):
        self.loop = loop
        self.conn = None
        self.uuid = uuid.uuid4()
        self.other_clients = []

    def connection_made(self, transport):
        print("Connected to server")
        self.conn = transport

        m = "hello"
        self.conn.write(m)

    def data_received(self, data):
        print('Data received: {!r}'.format(data))


    def connection_lost(self, exc):
        print('The server closed the connection')
        print('Stop the event loop')
        self.loop.stop()



# note that in my use-case, main() is called continuously by an external game engine
client_init = False
def main():
    # use a global here only for the purpose of providing example code runnable outside of aforementioned game engine
    global client_init

    if client_init != True:
        loop = asyncio.get_event_loop()
        coro = loop.create_connection(lambda: ClientProtocol(loop), '127.0.0.1', port)
        task = asyncio.Task(coro)

        transport, protocol = loop.run_until_complete(coro)

        client_init = True

    # to avoid blocking the execution of main (and of game engine calling it), only run one iteration of the event loop
    loop.stop()
    loop.run_forever()

    if transport:
        transport.write("some data")

if __name__ == "__main__":
    main()

Traceback:

Traceback (most recent call last):
  File "TCPclient.py", line 57, in <module>
    main()
  File "TCPclient.py", line 45, in main
    transport, protocol = loop.run_until_complete(coro)
  File "/usr/lib/python3.5/asyncio/base_events.py", line 337, in run_until_complete
    return future.result()
  File "/usr/lib/python3.5/asyncio/futures.py", line 274, in result
    raise self._exception
  File "/usr/lib/python3.5/asyncio/tasks.py", line 239, in _step
    result = coro.send(None)
  File "/usr/lib/python3.5/asyncio/base_events.py", line 599, in create_connection
    yield from tasks.wait(fs, loop=self)
  File "/usr/lib/python3.5/asyncio/tasks.py", line 341, in wait
    return (yield from _wait(fs, timeout, return_when, loop))
  File "/usr/lib/python3.5/asyncio/tasks.py", line 424, in _wait
    yield from waiter
  File "/usr/lib/python3.5/asyncio/futures.py", line 359, in __iter__
    assert self.done(), "yield from wasn't used with future"
AssertionError: yield from wasn't used with future

Ответ 1

Проблема заключается в том, что вы создаете задачу из своей сопрограммы, но затем передаете сопрограмму вместо run_until_complete:

    coro = loop.create_connection(lambda: ClientProtocol(loop), '127.0.0.1', port)
    task = asyncio.Task(coro)

    transport, protocol = loop.run_until_complete(coro)

Либо выполните задачу:

    coro = loop.create_connection(lambda: ClientProtocol(loop), '127.0.0.1', port)
    task = asyncio.Task(coro)

    transport, protocol = loop.run_until_complete(task)

Или не создавайте задачу и не передавайте сопрограмму. run_until_complete создаст для вас задачу

    coro = loop.create_connection(lambda: ClientProtocol(loop), '127.0.0.1', port)

    transport, protocol = loop.run_until_complete(coro)

Кроме того, вам необходимо убедиться, что строки, которые вы пишете, являются байтовыми строками. Строковые литералы в Python 3 по умолчанию для unicode. Вы можете либо закодировать их, либо просто написать строки байтов в первую очередь

    transport.write("some data".encode('utf-8'))
    transport.write(b"some data")

EDIT Мне не понятно, почему это проблема, однако источник для run_until_complete должен сказать следующее:

ВНИМАНИЕ: Было бы катастрофой вызвать run_until_complete() с той же сопрограммой дважды - она обернет ее двумя разные Задачи, и это не может быть хорошо.

Я предполагаю, что создание задачи, а затем передача в сопрограмме (которая вызывает создание задачи) имеет тот же эффект.