Given an async iterator that yields raw binary data, iterate over it & yield every event encountered
(self, iterator: AsyncIterator[bytes])
| 408 | ... |
| 409 | |
| 410 | def aiter_bytes(self, iterator: AsyncIterator[bytes]) -> AsyncIterator[ServerSentEvent]: |
| 411 | """Given an async iterator that yields raw binary data, iterate over it & yield every event encountered""" |
| 412 | ... |
| 413 | |
| 414 | |
| 415 | 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