reactor.core.action

Class ForEachAction<T>

java.lang.Object

reactor.core.action.Action<java.lang.Iterable<T>>

reactor.core.action.ForEachAction<T>

All Implemented Interfaces:

Flushable<T>, Consumer<Event<java.lang.Iterable<T>>>

public class ForEachAction<T>
extends Action<java.lang.Iterable<T>>
implements Flushable<T>

Since:

1.1

Field Summary

Fields

Modifier and Type	Field and Description
static Event<java.lang.Object>	FOREACH_FLUSH

Fields inherited from interface reactor.core.action.Flushable

FLUSH_EVENT

Constructor Summary

Constructors

Constructor and Description
ForEachAction(java.lang.Iterable<T> defaultValues, Observable d, java.lang.Object successKey, java.lang.Object failureKey, java.lang.Object flushKey)
ForEachAction(Observable d, java.lang.Object successKey, java.lang.Object failureKey, java.lang.Object flushKey)

Method Summary

Modifier and Type	Method and Description
void	doAccept(Event<java.lang.Iterable<T>> value)
Flushable<T>	flush() Trigger flush on this component, generally draining any collected values.

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

FOREACH_FLUSH

public static final Event<java.lang.Object> FOREACH_FLUSH

Constructor Detail

ForEachAction

public ForEachAction(Observable d,
                     java.lang.Object successKey,
                     java.lang.Object failureKey,
                     java.lang.Object flushKey)

ForEachAction

public ForEachAction(java.lang.Iterable<T> defaultValues,
                     Observable d,
                     java.lang.Object successKey,
                     java.lang.Object failureKey,
                     java.lang.Object flushKey)

Method Detail

doAccept

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

Specified by:

doAccept in class Action<java.lang.Iterable<T>>

flush

public Flushable<T> flush()

Description copied from interface: Flushable

Trigger flush on this component, generally draining any collected values.

Specified by:

flush in interface Flushable<T>