public class SampleAction<T> extends BatchAction<T,T>
batchSize, dispatcher, first, flush, flushConsumer, index, next, timer, timespan, unit
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
SampleAction(Dispatcher dispatcher,
boolean first,
int maxSize,
long timespan,
TimeUnit unit,
Timer timer) |
SampleAction(Dispatcher dispatcher,
int maxSize) |
SampleAction(Dispatcher dispatcher,
int maxSize,
boolean first) |
Modifier and Type | Method and Description |
---|---|
protected void |
firstCallback(T event) |
protected void |
flushCallback(T event) |
protected void |
nextCallback(T event) |
String |
toString() |
createTrackingSubscription, doComplete, doNext, getDispatcher, isReactivePull
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
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 SampleAction(Dispatcher dispatcher, int maxSize)
public SampleAction(Dispatcher dispatcher, boolean first, int maxSize, long timespan, TimeUnit unit, Timer timer)
public SampleAction(Dispatcher dispatcher, int maxSize, boolean first)
protected void firstCallback(T event)
firstCallback
in class BatchAction<T,T>
protected void nextCallback(T event)
nextCallback
in class BatchAction<T,T>
protected void flushCallback(T event)
flushCallback
in class BatchAction<T,T>
public String toString()
toString
in class BatchAction<T,T>
Copyright © 2017. All rights reserved.