A stream to read with async for (Effect's AsyncIterable).
Make one with Stream.to_async_iterable (or _with / _effect
for a stream that needs services).
Functions#
__init__#
__init__(chunks, context) -> None| Parameter | Type | Description |
|---|---|---|
chunks | StreamChannel[A_co, Any, Any] | |
context | Context |
def __init__(self, chunks: StreamChannel[A_co, Any, Any], context: Context) -> None:
self._channel = chunks
self._context = context