我想用PyAudio
库在异步上下文中,但库的主要入口点只有一个基于回调的 API:
import pyaudio
def callback(in_data, frame_count, time_info, status):
# Do something with data
pa = pyaudio.PyAudio()
self.stream = self.pa.open(
stream_callback=callback
)
我希望如何使用它是这样的:
pa = SOME_ASYNC_COROUTINE()
async def listen():
async for block in pa:
# Do something with block
问题是,我不确定如何将此回调语法转换为在回调触发时完成的 future 。在 JavaScript 中,我会使用
promise.promisify()
,但 Python 似乎没有这样的东西。
最佳答案
相当于 promisify
不适用于此用例,原因有两个:
这是一种可能的实现:
def make_iter():
loop = asyncio.get_event_loop()
queue = asyncio.Queue()
def put(*args):
loop.call_soon_threadsafe(queue.put_nowait, args)
async def get():
while True:
yield await queue.get()
return get(), put
make_iter
返回 对 pyaudio.open
, 而异步迭代器应该给 async for
在 asyncio 协程中,它将在等待下一个值时暂停:async def main():
stream_get, stream_put = make_iter()
stream = pa.open(stream_callback=stream_put)
stream.start_stream()
async for in_data, frame_count, time_info, status in stream_get:
# ...
asyncio.get_event_loop().run_until_complete(main())
注意,根据documentation ,回调也必须返回 一个有意义的值,一个帧元组和一个 bool 标志。这可以通过更改
fill
来合并到设计中。函数也接收来自 asyncio 端的数据。不包括实现,因为如果不了解域,它可能没有多大意义。
关于python - 将带有回调的 Python 函数转换为可等待的 asyncio,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53993334/