stream

Subscription matching: channel inference + namespace prefix filtering.

Direct port of libs/sdk/src/client/stream/subscription.ts from the JS SDK.

Stream controller: subscription registry and fan-out for AsyncThreadStream.

StreamController manages the set of active subscriptions against one shared SSE connection, routing events from the shared stream to per-subscription queues. It is the centralised place for:

• subscription registration / teardown
• shared-stream lifecycle (open, rotate, close)
• dedup of replayed events across rotations
• fan-out from the shared stream to subscriber queues

Unbounded async-iterable append-only log with per-iterator cursors.

Direct port of libs/sdk/src/client/stream/multi-cursor-buffer.ts. Each async for loop gets its own cursor starting at position 0, so late consumers still see all previously buffered items. Lifetime is bounded by the owning projection / handle; there is no eviction policy.

Synchronous shared-stream fan-out controller for v3 thread streaming.

Public exports for the v3 streaming transport layer.