reactor.core.action

Class Action<T>

java.lang.Object

reactor.core.action.Action<T>

Type Parameters:

T - The type of the values

All Implemented Interfaces:

Consumer<Event<T>>

Direct Known Subclasses:

BatchAction, CallbackAction, CallbackEventAction, ConnectAction, CountAction, DistinctAction, FilterAction, FlushableAction, ForEachAction, MapAction, MapManyAction, ScanAction, SupplyAction, TimeoutAction, WhenAction, WindowAction

public abstract class Action<T>
extends java.lang.Object
implements Consumer<Event<T>>

Base class for all Composable actions such as map, reduce, filter...

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Action(Observable observable, java.lang.Object successKey)
protected	Action(Observable observable, java.lang.Object successKey, java.lang.Object failureKey)

Method Summary

Modifier and Type	Method and Description
void	accept(Event<T> tEvent) Execute the logic of the action, accepting the given parameter.
protected abstract void	doAccept(Event<T> ev)
java.lang.Object	getFailureKey()
Observable	getObservable()
java.lang.Object	getSuccessKey()
protected void	notifyError(java.lang.Throwable error) Notify this Composable that an error is being propagated through this Observable.
protected void	notifyValue(Event<?> value)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Action

protected Action(Observable observable,
                 java.lang.Object successKey,
                 java.lang.Object failureKey)

Action

protected Action(Observable observable,
                 java.lang.Object successKey)

Method Detail

accept

public final void accept(Event<T> tEvent)

Description copied from interface: Consumer

Execute the logic of the action, accepting the given parameter.

Specified by:

accept in interface Consumer<Event<T>>

Parameters:

tEvent - The parameter to pass to the consumer.

getObservable

public Observable getObservable()

getSuccessKey

public java.lang.Object getSuccessKey()

getFailureKey

public java.lang.Object getFailureKey()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

notifyValue

protected void notifyValue(Event<?> value)

notifyError

protected void notifyError(java.lang.Throwable error)

Notify this Composable that an error is being propagated through this Observable.

Parameters:

error - the error to propagate

doAccept

protected abstract void doAccept(Event<T> ev)