Использование streamz в асинхронном обратном вызове торнадо

Question

Я пытаюсь использовать потоки из библиотеки streamz и пытаюсь использовать ее асинхронно.Я попробовал это и с питоном 3.6 и 3.7, но продолжаю получать TypeError.

из tornado import gen

из tornado.ioloop import IOLoop

async def fo ():

while True:

    await gen.sleep(0.100)

    await source.emit(create_record(),asynchronous=True)

IOLoop.current (). Add_callback(fo)

tornado.application - ERROR - Исключение в обратном вызове functools.partial (>,: 4> exception = TypeError ("объект NoneType не может использоваться в выражении 'await'"))>) Traceback(последний вызов был последним): файл "", строка 8, в файле await source.emit (create_record (), asynchronous = True) TypeError: объект NoneType нельзя использовать в выражении 'await'

Anyидеи о том, что происходит?Спасибо за вашу помощь