start(
self,
sink: Callable[[ExternalEvent], Awaitable[None]],
) -> None| Name | Type | Description |
|---|---|---|
sink* | Callable[[ExternalEvent], Awaitable[None]] | Async callback invoked with each decoded event. |
Start listening for newline-delimited JSON events.