Protected ReadonlyactionProtected ReadonlyactorProtected ReadonlyactorsProtected ReadonlyactorsProtected ReadonlydependencyReadonlynameThe name for this bus.
Protected ReadonlyobserversIndicate that the given actor has the given actor dependencies.
This will ensure that the given actor will be present in the bus before the given dependencies.
A dependent actor that will be placed before the given actors.
Actor dependencies that will be placed after the given actor.
ProtectedgetProtectedgetInvoked when an action was run by an actor.
The action on which the Actor#run method was invoked.
The original action input.
A promise resolving to the final action output.
Publish an action to all actors in the bus to test if they can run the action.
An action to publish
An array of reply objects. Each object contains a reference to the actor, and a promise to its Actor#test result.
Subscribe the given actor to the bus. After this, the given actor can be unsubscribed from the bus by calling Bus#unsubscribe.
An actor that is subscribed multiple times will exist that amount of times in the bus.
The actor to subscribe.
Subscribe the given observer to the bus. After this, the given observer can be unsubscribed from the bus by calling Bus#unsubscribeObserver.
An observer that is subscribed multiple times will exist that amount of times in the bus.
The observer to subscribe.
Unsubscribe the given actor from the bus.
An actor that is subscribed multiple times will be unsubscribed only once.
The actor to unsubscribe
If the given actor was successfully unsubscribed, otherwise it was not subscribed before.
Unsubscribe the given observer from the bus.
An observer that is subscribed multiple times will be unsubscribed only once.
The observer to unsubscribe.
If the given observer was successfully unsubscribed, otherwise it was not subscribed before.
Bus inspired by BusIndexed but specific for function factory.
The implementation differs. In BusIndexed, each actor is indexed only once. Here, a single actor can be indexed multiple times (max 2).