reactor.core.action

Class BatchAction<T>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.BatchAction<T>

All Implemented Interfaces:

Consumer<Event<T>>

Direct Known Subclasses:

BufferAction, CollectAction, ReduceAction

public class BatchAction<T>
extends Action<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.ReentrantLock	lock

Constructor Summary

Constructors

Constructor and Description
BatchAction(int batchSize, Observable d, java.lang.Object successKey, java.lang.Object failureKey)
BatchAction(int batchSize, Observable d, java.lang.Object successKey, java.lang.Object failureKey, java.lang.Object flushKey, java.lang.Object firstKey)

Method Summary

Modifier and Type	Method and Description
void	doAccept(Event<T> value)
protected void	doFirst(Event<T> event)
protected void	doFlush(Event<T> event)
protected void	doNext(Event<T> event)
long	getAcceptCount()
int	getBatchSize()
long	getErrorCount()
java.lang.Object	getFirstKey()
java.lang.Object	getFlushKey()
protected void	notifyError(java.lang.Throwable error) Notify this Composable that an error is being propagated through this Observable.
java.lang.String	toString()

Methods inherited from class reactor.core.action.Action

accept, getFailureKey, getObservable, getSuccessKey, notifyValue

Methods inherited from class java.lang.Object

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

Field Detail

lock

protected final java.util.concurrent.locks.ReentrantLock lock

Constructor Detail

BatchAction

public BatchAction(int batchSize,
                   Observable d,
                   java.lang.Object successKey,
                   java.lang.Object failureKey)

BatchAction

public BatchAction(int batchSize,
                   Observable d,
                   java.lang.Object successKey,
                   java.lang.Object failureKey,
                   java.lang.Object flushKey,
                   java.lang.Object firstKey)

Method Detail

getFlushKey

public java.lang.Object getFlushKey()

getFirstKey

public java.lang.Object getFirstKey()

getErrorCount

public long getErrorCount()

getAcceptCount

public long getAcceptCount()

getBatchSize

public int getBatchSize()

doNext

protected void doNext(Event<T> event)

doFlush

protected void doFlush(Event<T> event)

doFirst

protected void doFirst(Event<T> event)

doAccept

public void doAccept(Event<T> value)

Specified by:

doAccept in class Action<T>

notifyError

protected void notifyError(java.lang.Throwable error)

Description copied from class: Action

Notify this Composable that an error is being propagated through this Observable.

Overrides:

notifyError in class Action<T>

Parameters:

error - the error to propagate

toString

public java.lang.String toString()

Overrides:

toString in class Action<T>