nemo_microservices._utils._streams#
Module Contents#
Functions#
API#
- async nemo_microservices._utils._streams.consume_async_iterator(
- iterator: typing_extensions.AsyncIterator[Any],
- nemo_microservices._utils._streams.consume_sync_iterator(
- iterator: typing_extensions.Iterator[Any],