code: def _multiprocessing_to_asyncio(in_queue, out_queue, loop):
      
  
      while True:
          value = in_queue.get()
          loop.call_soon_threadsafe(out_queue.put_nowait, value)
docs: Bridge between a synchronous multiprocessing queue
      and an asynchronous asyncio queue.
  
      Args:
          in_queue (multiprocessing.Queue): input queue
          out_queue (asyncio.Queue): output queue