asyncflux.util – General-purpose utilities

asyncflux.util.asyncflux_coroutine(f)

A coroutine that accepts an optional callback.

Given a callback, the function returns None, and the callback is run with (result, error). Without a callback the function returns a Future.

asyncflux.util.sanitize_url(url)

asyncflux.util.batches(source, batch_size)