Asynchronize is designed for situations where you are using a library that provides a callback interface, but you want to work with the convenience of await or async for.

To install Asynchronize, run:

pip install asynchronize

First, let's say you're working with a library that's designed to call step_callback each time it receives a new chunk of data, and then end_callback once it's finished. sounddevice.InputStream works like this:

library=MultiThreadedLibrary( step_callback=step_callback, end_callback=end_callback )

With sounddevice.InputStream, this looks like:

importsounddeviceassdsd.InputStream( channels=2, callback=step_callback, finished_callback=finished_callback )

To convert this library into an async generator you can iterate with async for, all you need to do is instantiate asynchronize.AsyncCallback, and pass its methods into whatever is expecting the callbacks:

importasynchronizecallback=asynchronize.AsyncCallback() lib=MultiThreadedLibrary( step_callback=callback.step_callback, end_callback=callback.finished_callback, ) lib.start() asyncforvalincallback: # Do something with valpass

This time, let's assume that the library is designed to call a single callback once it's processed something, and after that it's done. For example:

lib=MultiThreadedLibrary( callback=callback, )

To convert this library into an awaitable, instantiate asynchronize.AsyncCallback as before, but this time you only need to pass in the finished_callback:

importasynchronizecallback=asynchronize.AsyncCallback() lib=MultiThreadedLibrary( end_callback=callback.finished_callback ) lib.start() val=awaitcallback

A more complicated, real-world example is available in example.py.

In addition, the unit tests can be a useful example on how to use the library, from end to end: test_general.py.

Asynchronize is actually very simple. The only public class is asynchronize.AsyncCallback, and its constructor has no arguments. The only way to use the class is by passing step_callback or finished_callback to something that expects a callback. That's all!