ReactiveEventTransformer<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
- Inheritance
-
- Object
- EventTransformer<
EVENT, Stream< NEW_EVENT> > - ReactiveEventTransformer
- Implementers
Constructors
- ReactiveEventTransformer()
-
const
-
ReactiveEventTransformer.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