public class BufferAction<T> extends BatchAction<T,List<T>>
batchSize, dispatcher, first, flush, flushConsumer, index, next, timer, timespan, unit
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
BufferAction(Dispatcher dispatcher,
int batchsize) |
BufferAction(Dispatcher dispatcher,
int maxSize,
long timespan,
TimeUnit unit,
Timer timer) |
Modifier and Type | Method and Description |
---|---|
protected void |
doError(Throwable ev) |
void |
flushCallback(T ev) |
void |
nextCallback(T value) |
createTrackingSubscription, doComplete, doNext, firstCallback, getDispatcher, isReactivePull, toString
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, debug, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, requestUpstream, subscribe, subscribeWithSubscription, toBroadcastCompleteConsumer, toBroadcastErrorConsumer, toBroadcastNextConsumer
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
public BufferAction(Dispatcher dispatcher, int batchsize)
public BufferAction(Dispatcher dispatcher, int maxSize, long timespan, TimeUnit unit, Timer timer)
public void nextCallback(T value)
nextCallback
in class BatchAction<T,List<T>>
public void flushCallback(T ev)
flushCallback
in class BatchAction<T,List<T>>
Copyright © 2017. All rights reserved.