EventStreamHandle(
self,
events: AsyncIterator[Event],
ready: asyncio.Future[None],
done: asyncio| Name | Type |
|---|---|
| events | AsyncIterator[Event] |
| ready | asyncio.Future[None] |
| done | asyncio.Future[BaseException | None] |
| close | Callable[[], Awaitable[None]] |
Handle for one async filtered event stream.