streaming.receiver

zen_api_utils.streaming.receiver

Asynchronous helpers for ZEN pixel-stream consumers.

Functions:

• merge_channel_streams –

  Merge channel streams while preserving the source channel index.

• close_async_iterator –

  Close an asynchronous iterator when it supports aclose.

merge_channel_streams async

merge_channel_streams(streams: list[tuple[int, AsyncIterable[Any]]]) -> AsyncIterator[tuple[int, Any]]

Merge channel streams while preserving the source channel index.

close_async_iterator async

close_async_iterator(iterator: AsyncIterator[Any]) -> None

Close an asynchronous iterator when it supports aclose.