reactor.core.action

Class BufferAction<T>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.BatchAction<T>

reactor.core.action.BufferAction<T>

All Implemented Interfaces:

Flushable<T>, Consumer<Event<T>>

public class BufferAction<T>
extends BatchAction<T>
implements Flushable<T>

Since:

1.1

Field Summary

Fields

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

Fields inherited from class reactor.core.action.BatchAction

lock

Fields inherited from interface reactor.core.action.Flushable

FLUSH_EVENT

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class reactor.core.action.BatchAction

doAccept, doFirst, getAcceptCount, getBatchSize, getErrorCount, getFirstKey, getFlushKey, notifyError, 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

BUFFER_FLUSH

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

Constructor Detail

BufferAction

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

Method Detail

doNext

public void doNext(Event<T> value)

Overrides:

doNext in class BatchAction<T>

doFlush

public void doFlush(Event<T> value)

Overrides:

doFlush in class BatchAction<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>