Stream operation utils ====================== .. autofunction:: moulinette.utils.stream.consume_queue .. autofunction:: moulinette.utils.stream.async_file_reading