AsyncThreadStream

Return a fresh subscription to ALL channels.

Each property access opens a new subscription; callers iterating twice will see two independent streams (both filtered by the same channel union). Terminates when the stream closes (server hangup, __aexit__, or transport-level close).

Tear down the thread stream. Idempotent.

Advance the reconnect cursor from a command response meta sequence.

Open a typed subscription against the shared SSE.

Returns an async iterator that yields raw Event dicts matching the given filter. Multiple concurrent subscribes share one HTTP connection whose union expands or rotates as subscriptions come and go.