controller

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