InMemoryEventBus class
No-op EventBus suitable for single-process tests.
Notifications are short-circuited through the WorkflowStore since the runtime already knows which runs are awaiting a topic.
- Implemented types
Constructors
- InMemoryEventBus(WorkflowStore store)
-
Creates an in-memory event bus bound to a
store.
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- store → WorkflowStore
-
Workflow store used to resolve waiting runs.
final
Methods
-
emit(
String topic, Map< String, Object?> payload) → Future<void> -
Simply drops the event because the runtime fetches waiting runs directly
from the store.
override
-
fanout(
String topic) → Future< int> -
Returns zero because there is no fan-out beyond the calling isolate.
override
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited