Class●Since v0.3

StreamController

StreamController(
  self,
  *,
  transport: AsyncProtocolTransport,
  run_start_gate: Callable[[], Awaitable[None

Constructors

Name	Type	Description
`transport`*	`AsyncProtocolTransport`	the `AsyncProtocolTransport` bound to this thread session.
`run_start_gate`	`Callable[[], Awaitable[None]] \| None`	Default:`None` zero-argument async callable that resolves once the current `run.start` has committed server-side (no-op when no run is in flight).
`max_queue_size`	`int`	Default:`1024`
`seen_event_ids_max`	`int`	Default:`10000`

constructor

__init__

Name	Type
transport	AsyncProtocolTransport
run_start_gate	Callable[[], Awaitable[None]] \| None
max_queue_size	int
seen_event_ids_max	int
max_reconnect_attempts	int
reconnect_backoff_base	float
reconnect_backoff_cap	float