Pause the subscription: resolve all waiting iterators with done: true so for await loops exit, but keep the subscription alive. New events arriving while paused are still buffered. Call resume() to allow iterators to consume again.

method

push

method

resume

Resume a paused subscription so new for await loops can consume buffered and future events.

method

unsubscribe→ Promise<void>

method

waitForResume→ Promise<void>

Returns a promise that resolves when resume() is called. Resolves immediately if not currently paused.

Async iterable handle for raw event subscriptions.

An optional transform maps each incoming event before it is queued or delivered to a waiting consumer. This is used by named custom channel subscriptions (e.g. "custom:a2a") to unwrap the payload so callers receive the raw emitted data instead of the protocol event envelope.

Menu

SubscriptionHandle

Constructors

Properties

Methods