Given an async iterator that yields raw binary data, iterate over it & yield every event encountered
(self, iterator: AsyncIterator[bytes])
| 529 | ... |
| 530 | |
| 531 | def aiter_bytes(self, iterator: AsyncIterator[bytes]) -> AsyncIterator[ServerSentEvent]: |
| 532 | """Given an async iterator that yields raw binary data, iterate over it & yield every event encountered""" |
| 533 | ... |
| 534 | |
| 535 | |
| 536 | def is_stream_class_type(typ: type) -> TypeGuard[type[Stream[object]] | type[AsyncStream[object]]]: |
nothing calls this directly
no outgoing calls
no test coverage detected