reactor.core.action

Class CallbackAction<T>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.CallbackAction<T>

All Implemented Interfaces:

Consumer<Event<T>>

public class CallbackAction<T>
extends Action<T>

Constructor Summary

Constructors

Constructor and Description
CallbackAction(Consumer<T> consumer, Observable d, java.lang.Object failureKey)

Method Summary

Modifier and Type	Method and Description
void	doAccept(Event<T> value)

Methods inherited from class reactor.core.action.Action

accept, getFailureKey, getObservable, getSuccessKey, notifyError, notifyValue, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CallbackAction

public CallbackAction(Consumer<T> consumer,
                      Observable d,
                      java.lang.Object failureKey)

Method Detail

doAccept

public void doAccept(Event<T> value)

Specified by:

doAccept in class Action<T>