public final class BufferShiftAction<T> extends Action<T,List<T>>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
BufferShiftAction(Dispatcher dispatcher,
int size,
int skip) |
BufferShiftAction(Dispatcher dispatcher,
int size,
int skip,
long timeshift,
long timespan,
TimeUnit unit,
Timer timer) |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<T> |
createTrackingSubscription(org.reactivestreams.Subscription subscription) |
protected void |
doComplete() |
protected void |
doError(Throwable ev) |
protected void |
doNext(T value) |
protected void |
doOnSubscribe(org.reactivestreams.Subscription subscription) |
String |
toString() |
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, debug, 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, getDispatcher, getEnvironment, getTimer, groupBy, ignoreError, ignoreError, isReactivePull, 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 BufferShiftAction(Dispatcher dispatcher, int size, int skip)
public BufferShiftAction(Dispatcher dispatcher, int size, int skip, long timeshift, long timespan, TimeUnit unit, Timer timer)
protected void doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class Action<T,List<T>>
protected PushSubscription<T> createTrackingSubscription(org.reactivestreams.Subscription subscription)
createTrackingSubscription
in class Action<T,List<T>>
protected void doComplete()
doComplete
in class Action<T,List<T>>
Copyright © 2017. All rights reserved.