SavingReactiveEventTransformer<EVENT extends Object, NEW_EVENT extends Object> class
abstract
- Listens to an event
- Executes a function that returns a stream
- Listens to the stream
- Publishes the message as the stream emits
- Saves the message to store
- Inheritance
-
- Object
- EventTransformer<
EVENT, Stream< NEW_EVENT> > - ReactiveEventTransformer<
EVENT, NEW_EVENT> - SavingReactiveEventTransformer
Constructors
- SavingReactiveEventTransformer()
-
const
-
SavingReactiveEventTransformer.fromFn(ParameterizedCallback<
EVENT, Stream< transformFunction)NEW_EVENT> > -
factory
Properties
Methods
-
execute(
EVENT event, EventBus bus) → Stream< NEW_EVENT> -
inherited
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
publish(
Stream< NEW_EVENT> newEvent, EventBus bus) → void -
override
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited