| 29 | |
| 30 | |
| 31 | class ByteStream(AsyncByteStream, SyncByteStream): |
| 32 | def __init__(self, stream: bytes) -> None: |
| 33 | self._stream = stream |
| 34 | |
| 35 | def __iter__(self) -> Iterator[bytes]: |
| 36 | yield self._stream |
| 37 | |
| 38 | async def __aiter__(self) -> AsyncIterator[bytes]: |
| 39 | yield self._stream |
| 40 | |
| 41 | |
| 42 | class IteratorByteStream(SyncByteStream): |
no outgoing calls
no test coverage detected