reactor.core.action

Class FlushableAction

java.lang.Object

reactor.core.action.Action<java.lang.Object>

reactor.core.action.FlushableAction

All Implemented Interfaces:

Consumer<Event<java.lang.Object>>

public class FlushableAction
extends Action<java.lang.Object>

Since:

1.1

Constructor Summary

Constructors

Constructor and Description
FlushableAction(Flushable<?> flushable, Observable observable, java.lang.Object failureKey)

Method Summary

Modifier and Type	Method and Description
void	doAccept(Event<java.lang.Object> value)
Flushable<?>	getFlushable()
java.lang.String	toString()

Methods inherited from class reactor.core.action.Action

accept, getFailureKey, getObservable, getSuccessKey, notifyError, notifyValue

Methods inherited from class java.lang.Object

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

Constructor Detail

FlushableAction

public FlushableAction(Flushable<?> flushable,
                       Observable observable,
                       java.lang.Object failureKey)

Method Detail

doAccept

public void doAccept(Event<java.lang.Object> value)

Specified by:

doAccept in class Action<java.lang.Object>

toString

public java.lang.String toString()

Overrides:

toString in class Action<java.lang.Object>

getFlushable

public Flushable<?> getFlushable()