reactor.core.action

Class FilterAction<T>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.FilterAction<T>

All Implemented Interfaces:

Consumer<Event<T>>

public class FilterAction<T>
extends Action<T>

Since:

1.1

Field Summary

Fields

Modifier and Type	Field and Description
static Predicate<java.lang.Boolean>	simplePredicate

Constructor Summary

Constructors

Constructor and Description
FilterAction(Predicate<T> p, Observable d, java.lang.Object successKey, java.lang.Object failureKey, Observable elseObservable, java.lang.Object elseSuccess)

Method Summary

Modifier and Type	Method and Description
void	doAccept(Event<T> value)
Observable	getElseObservable()
java.lang.Object	getElseSuccess()

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

Field Detail

simplePredicate

public static final Predicate<java.lang.Boolean> simplePredicate

Constructor Detail

FilterAction

public FilterAction(Predicate<T> p,
                    Observable d,
                    java.lang.Object successKey,
                    java.lang.Object failureKey,
                    Observable elseObservable,
                    java.lang.Object elseSuccess)

Method Detail

doAccept

public void doAccept(Event<T> value)

Specified by:

doAccept in class Action<T>

getElseSuccess

public java.lang.Object getElseSuccess()

getElseObservable

public Observable getElseObservable()