def _multiprocessing_to_asyncio(in_queue, out_queue, loop):
    """Bridge between a synchronous multiprocessing queue
    and an asynchronous asyncio queue.

    Args:
        in_queue (multiprocessing.Queue): input queue
        out_queue (asyncio.Queue): output queue
    """

    while True:
        value = in_queue.get()
        loop.call_soon_threadsafe(out_queue.put_nowait, value)
Bridge between a synchronous multiprocessing queue
and an asynchronous asyncio queue.

Args:
in_queue (multiprocessing.Queue): input queue
out_queue (asyncio.Queue): output queue
bigchaindb/web/websocket_server.py