Как я могу создать асинхронную программу с помощью urwid и asyncio? - PullRequest
Новая
       32

Как я могу создать асинхронную программу с помощью urwid и asyncio?

0 голосов
/ 10 июля 2019

Я хочу построить чат с aiortc. Прежде всего, я хочу создать макет с urwid как cli и asyncio. Часть urwid уже работает нормально, возможен ввод данных пользователем. Я знаю, хочу запустить сопрограмму, которая генерирует случайный текст и работает как чат-клиенты, отправляющие текстовые сообщения в этом чате.

Я попытался запустить функцию urwid с mainloop как asyncio coroutine, но безуспешно. Я не знаю, как интегрировать асинхронную функцию в основной цикл urwid. 

def unhandled(key):
    """
    functin to handle input
    """
    global TEXT_INPUT
    global lw_user_input
    global lw_chatroom
    global listbox_chatroom

    if not isinstance(key, tuple):
        if key == 'enter':
            del lw_user_input[-1]
            # create widegt and fill with user input
            lw_chatroom.append(widget)
            TEXT_INPUT = ""
            listbox_chatroom.set_focus(len(lw_chatroom)-1, 'above')

        elif key == 'esc':
            raise urwid.ExitMainLoop()
        elif key == 'backspace':
            if len(lw_user_input) > 0:
                user_input = lw_user_input[0].get_text()[0]
                user_input = user_input[:-1]
                del lw_user_input[-1]
                TEXT_INPUT = user_input
                lw_user_input.append(urwid.Text(TEXT_INPUT))
        else:
            TEXT_INPUT += key  # repr(key)
            if len(lw_user_input) > 0:
                del lw_user_input[-1]
                lw_user_input.append(urwid.Text(TEXT_INPUT))
            else:
                lw_user_input.append(urwid.Text(key))



def generate_output():
    global lw_chatroom
    global listbox_chatroom
    while True:
        # generate text and widgets and post with delay
        lw_chatroom.append(chat_widget)
        listbox_chatroom.set_focus(len(lw_chatroom)-1, 'above')


def create_cli():
    # generate all widgets
    uloop = urwid.MainLoop(frame, palette, screen,
                           unhandled_input=unhandled)
    uloop.start()


if __name__ == '__main__':
    create_cli()

Я хочу запускать generate_output () и unhandled (key) асинхронно. Я понятия не имею, как.

1 Ответ

0 голосов
/ 14 июля 2019

Хорошо, я понял это.

Это так просто: 

aloop = asyncio.get_event_loop()

ev_loop = urwid.AsyncioEventLoop(loop=aloop)
loop = urwid.MainLoop(frame, palette, screen,
                      unhandled_input=unhandled, event_loop=ev_loop)
aloop.create_task(generate_output())
loop.run()
...