Runtime context providing live access to the registered IActiveTaskTracker. Read on every event dispatch so adapter swaps after construction are picked up immediately.
ReadonlycompletionObservable for components to subscribe to completion events in real-time. Emits enriched completion data once per agent finish.
Clear a recent completion after the late-mounting component has handled it.
Tear down subscriptions and clear state. Call at app shutdown or in tests between cases.
Current connection status value (synchronous).
Current connection status as an observable.
Diagnostic snapshot for a specific message — used by debugging tools to dump live in-memory state.
Replay a recently completed event so a late-mounting component can pick it up.
Returns undefined if no completion is in the 5-minute replay window.
Total number of registered callbacks (diagnostic).
Number of distinct messages currently being tracked (diagnostic).
Initialize the global PubSub subscription. Idempotent — safe to call multiple times. Should be called once at app startup (e.g., the Angular widget calls this when the workspace mounts).
Register a callback for a specific conversation detail (message). The callback is invoked whenever progress updates arrive for that message.
Unregister a callback for a specific conversation detail. When callback is
omitted, ALL callbacks for that message are removed.
Optionalcallback: MessageProgressCallback
Global streaming service that manages PubSub subscriptions for all conversations.
Maintains a single GraphQL subscription and routes updates to registered per-message callbacks, regardless of which conversation is currently visible. This ensures messages update correctly even when users navigate away and return.
Usually accessed via
ConversationsRuntime.Instance.Streaming.