reactor.core.action

Class ScanAction<T,A>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.ScanAction<T,A>

All Implemented Interfaces:

Consumer<Event<T>>

public class ScanAction<T,A>
extends Action<T>

Constructor Summary

Constructors

Constructor and Description
ScanAction(Supplier<A> accumulators, Function<Tuple2<T,A>,A> fn, Observable d, java.lang.Object successKey, java.lang.Object failureKey)

Method Summary

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

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

ScanAction

public ScanAction(Supplier<A> accumulators,
                  Function<Tuple2<T,A>,A> fn,
                  Observable d,
                  java.lang.Object successKey,
                  java.lang.Object failureKey)

Method Detail

doAccept

protected void doAccept(Event<T> ev)

Specified by:

doAccept in class Action<T>