Returns the count of subscribed event types (for health reporting).
Removes all subscriptions.
Internal method for lifecycle cleanup (NOT on IEventBus).
Publishes an event to every subscriber of its type.
The event payload type
The event to publish
Publishes multiple events, each to its own subscribers.
The events to publish, in array order
Subscribes to an event type.
The event payload type
Event type name
Invoked for each published event of the type
Call to remove the subscription
Resolves once all in-flight fire-and-forget handlers settle.
Internal test seam (concrete-class only, NOT on IEventBus).
In-memory publish/subscribe event bus.
Implements
IEventBus. Dispatch policy (async/errorHandler) is configured at construction. Handler errors are isolated througherrorHandlerand never causepublishto reject.M98j: when the plugin attached an observation collector, publish entry and each existing handler await are instrumented WITHOUT changing dispatch — no extra subscription, no reordering, no second handler evaluation. A thrown
errorHandlerkeeps its existing propagation behavior.Since
0.1.0