как настроить цикл событий с помощью txaio и запускать мои сопрограммы, используя txaio, перечисленные ниже - PullRequest
Новая
       5

как настроить цикл событий с помощью txaio и запускать мои сопрограммы, используя txaio, перечисленные ниже

0 голосов
/ 28 октября 2018

Я создал небольшое фиктивное приложение, чтобы знать концепцию txaio, но я не могу запустить свою асинхронную функцию при использовании txaio, то есть вспомогательной библиотеки. Пожалуйста, мне нужно знать, как заставить ее работать. 

import txaio
import time
import asyncio

txaio.use_asyncio()


async def  sum(n):
    print("inside sum")
    res = await disp2(n)
    #yield from asyncio.sleep(1)
    return res

async def disp2(val):
    print("inside def2")
    return val*200

fail =False

def callback(value):
    print("Callback:", value.result())

#loop = asyncio.get_event_loop()
td =txaio.with_config(loop=asyncio.get_event_loop())
t=td.as_future(sum,5)
td.add_callbacks(t,callback,None)
if not fail:  
    pass  
    td.resolve(t,"succ")
...