reactor.rx.action.aggregation

Class BatchAction<T,V>

java.lang.Object

reactor.rx.Stream<O>

reactor.rx.action.Action<T,V>

reactor.rx.action.aggregation.BatchAction<T,V>

All Implemented Interfaces:

org.reactivestreams.Processor<T,V>, org.reactivestreams.Publisher<V>, org.reactivestreams.Subscriber<T>, NonBlocking, Recyclable, Consumer<T>, Control

Direct Known Subclasses:

BufferAction, SampleAction, SortAction, WindowAction

public abstract class BatchAction<T,V>
extends Action<T,V>

Since:

1.1

Author:

Stephane Maldini

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchSize
protected Dispatcher	dispatcher
protected boolean	first
protected boolean	flush
protected Consumer<T>	flushConsumer
protected int	index
protected boolean	next
protected Timer	timer
protected long	timespan
protected TimeUnit	unit

Fields inherited from class reactor.rx.action.Action

capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription

Constructor Summary

Constructors

Constructor and Description
BatchAction(Dispatcher dispatcher, int batchSize, boolean next, boolean first, boolean flush)
BatchAction(Dispatcher dispatcher, int batchSize, boolean next, boolean first, boolean flush, long timespan, TimeUnit unit, Timer timer)

Method Summary

Modifier and Type	Method and Description
protected PushSubscription<T>	createTrackingSubscription(org.reactivestreams.Subscription subscription)
protected void	doComplete()
protected void	doNext(T value)
protected void	firstCallback(T event)
protected void	flushCallback(T event)
Dispatcher	getDispatcher() Get the dispatcher used to execute signals on this Stream instance.
boolean	isReactivePull(Dispatcher dispatcher, long producerCapacity) Get the assigned Dispatcher.
protected void	nextCallback(T event)
String	toString()

Methods inherited from class reactor.rx.action.Action

accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, debug, doError, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, requestUpstream, subscribe, subscribeWithSubscription, toBroadcastCompleteConsumer, toBroadcastErrorConsumer, toBroadcastNextConsumer

Methods inherited from class reactor.rx.Stream

adaptiveConsume, adaptiveConsumeOn, after, batchConsume, batchConsumeOn, broadcast, broadcastOn, broadcastTo, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cast, concatMap, concatWith, consume, consume, consume, consume, consume, consumeLater, consumeOn, consumeOn, consumeOn, count, count, decode, defaultIfEmpty, dematerialize, dispatchOn, dispatchOn, dispatchOn, distinct, distinct, distinctUntilChanged, distinctUntilChanged, elapsed, elementAt, elementAtOrDefault, encode, env, exists, fanIn, filter, filter, finallyDo, flatMap, getEnvironment, getTimer, groupBy, ignoreError, ignoreError, join, joinWith, keepAlive, last, lift, log, log, map, materialize, merge, mergeWith, nest, next, observe, observeCancel, observeComplete, observeError, observeStart, observeSubscribe, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturn, onOverflowBuffer, onOverflowDrop, partition, partition, process, recover, reduce, reduce, repeat, repeat, repeatWhen, requestWhen, retry, retry, retry, retry, retryWhen, sample, sample, sample, sample, sample, sample, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, scan, scan, skip, skip, skip, skipWhile, skipWhile, sort, sort, sort, sort, split, split, startWith, startWith, startWith, subscribe, subscribeOn, subscribeOn, subscribeOn, switchMap, take, take, take, takeWhile, tap, throttle, throttle, timeout, timeout, timeout, timeout, timestamp, toBlockingQueue, toBlockingQueue, toList, toList, unbounded, when, window, window, window, window, window, window, window, window, window, window, window, zip, zipWith, zipWith

Methods inherited from class java.lang.Object

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

Field Detail

next

protected final boolean next

flush

protected final boolean flush

first

protected final boolean first

batchSize

protected final int batchSize

dispatcher

protected final Dispatcher dispatcher

timespan

protected final long timespan

unit

protected final TimeUnit unit

timer

protected final Timer timer

flushConsumer

protected final Consumer<T> flushConsumer

index

protected int index

Constructor Detail

BatchAction

public BatchAction(Dispatcher dispatcher,
                   int batchSize,
                   boolean next,
                   boolean first,
                   boolean flush)

BatchAction

public BatchAction(Dispatcher dispatcher,
                   int batchSize,
                   boolean next,
                   boolean first,
                   boolean flush,
                   long timespan,
                   TimeUnit unit,
                   Timer timer)

Method Detail

createTrackingSubscription

protected PushSubscription<T> createTrackingSubscription(org.reactivestreams.Subscription subscription)

Overrides:

createTrackingSubscription in class Action<T,V>

isReactivePull

public boolean isReactivePull(Dispatcher dispatcher,
                              long producerCapacity)

Description copied from interface: NonBlocking

Get the assigned Dispatcher.

Specified by:

isReactivePull in interface NonBlocking

Overrides:

isReactivePull in class Stream<V>

Returns:

true if the component wishes to use a back-pressure ready message-passing (e.g., ReactiveSubscription)

nextCallback

protected void nextCallback(T event)

flushCallback

protected void flushCallback(T event)

firstCallback

protected void firstCallback(T event)

doNext

protected void doNext(T value)

Specified by:

doNext in class Action<T,V>

doComplete

protected void doComplete()

Overrides:

doComplete in class Action<T,V>

toString

public String toString()

Overrides:

toString in class Action<T,V>

getDispatcher

public final Dispatcher getDispatcher()

Description copied from class: Stream

Get the dispatcher used to execute signals on this Stream instance.

Overrides:

getDispatcher in class Stream<V>

Returns:

assigned dispatcher