Как написать асинхронный адаптер для PyAudio?

Question

[serhiops]

import sys
import asyncio
import pyaudio

def callback(queue: asyncio.Queue, input: bytes, frames: int, time: dict, status: int):
  print('callback')
  queue.put_nowait(input)
  return None, pyaudio.paContinue

class InputAudio():
  def __init__(self, pyaudio):
    self.queue = asyncio.Queue()
    self.stream = pyaudio.open(format=pyaudio.get_format_from_width(2),
      channels=1 if sys.platform == 'darwin' else 2,
      rate=44100,
      input=True,
      stream_callback=lambda a, b, c, d: callback(self.queue, a, b, c, d)
    )

  def __aiter__(self):
    return self
  
  async def __anext__(self):
    print('__anext__')
    return await self.queue.get()
  
  def close(self): self.stream.close()

async def main():
  p = pyaudio.PyAudio()

  input = InputAudio(p)

  output = p.open(format=p.get_format_from_width(2),
    channels=1 if sys.platform == 'darwin' else 2,
    rate=44100,
    output=True)

  async for data in input:
    print('here')
    output.write(data)

  input.close()
  output.close()
  p.terminate()

asyncio.run(main())

Вызывается один раз __anext__ и много раз callback:

__anext__
callback
callback
callback
...

Может ли это связанно с тем что PyAudio запускает callback в отдельном потоке?
Это игрушечный пример, и все нужно сделать именно через 2 отдельных стрима

P.S
Немного разобрался, вот рабочая версия(правда с большим отставанием)

import sys
import asyncio
import pyaudio
from typing import Callable
from queue import Queue

class InputAudio():

  def __init__(self, audio):
    self.futures: Queue[asyncio.Future] = Queue()
    self.buffer = Queue()
    self.loop = asyncio.get_running_loop()
    def callback(input: bytes, frames: int, time: dict, status: int):
      if self.futures.qsize() > 0:
        future = self.futures.get_nowait()
        self.loop.call_soon_threadsafe(lambda: future.set_result(input))
      else:
        self.buffer.put_nowait(input)
      return None, pyaudio.paContinue
    
    self.stream = audio.open(format=audio.get_format_from_width(2),
      channels=1 if sys.platform == 'darwin' else 2,
      rate=44100,
      input=True,
      stream_callback=callback
    )

  def __aiter__(self):
    return self
  
  def __anext__(self):
    future = self.loop.create_future()
    if self.buffer.qsize() > 0: future.set_result(self.buffer.get_nowait())
    else: self.futures.put_nowait(future)
    return future
  
  def close(self): self.stream.close()

async def main():
  p = pyaudio.PyAudio()
  input = InputAudio(p)
  output = p.open(format=p.get_format_from_width(2),
                channels=1 if sys.platform == 'darwin' else 2,
                rate=44100,
                output=True,
                frames_per_buffer=44100)
  async for data in input:
    output.write(data)

  input.close()
  p.terminate()

asyncio.run(main())

Но я все еще недостаточно разобрался в теме чтобы обьяснить это