while True:

            recents = [await msgs.get()]

            while not msgs.empty():

                recents.append(msgs.get_nowait())

            try:

                onMessage(graph, ctx, recents[-1])

            except Exception as e:

                traceback.print_exc()

                log.warning("error in onMessage- continuing anyway")

            await asyncio.sleep(1 / MAX_SEND_RATE)

    asyncio.create_task(reader())

    for inputName in mido.get_input_names():

        if inputName.startswith('Keystation'):

            dev = "keystation"

        elif inputName.startswith('BCF2000'):

            dev = 'bcf2000'

        elif inputName.startswith('QUNEO'):

            dev = 'quneo'

        else:

            continue

        log.info(f'listening on input {inputName} {dev=}')

    while True:

        await asyncio.sleep(1)

if __name__ == '__main__':

    asyncio.run(main())