public final class TimeoutAction<T> extends FallbackAction<T>
fallback
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
TimeoutAction(Dispatcher dispatcher,
org.reactivestreams.Publisher<? extends T> fallback,
Timer timer,
long timeout) |
Modifier and Type | Method and Description |
---|---|
protected void |
doNormalNext(T ev) |
protected void |
doShutdown() |
void |
requestMore(long req)
Request the next n elements from the source
|
doFallbackNext, doNext, doSwitch, requestUpstream
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doComplete, doError, doOnSubscribe, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, subscribe, subscribeWithSubscription, toBroadcastCompleteConsumer, toBroadcastErrorConsumer, toBroadcastNextConsumer, toString
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 TimeoutAction(Dispatcher dispatcher, org.reactivestreams.Publisher<? extends T> fallback, Timer timer, long timeout)
public void requestMore(long req)
Control
requestMore
in interface Control
requestMore
in class Action<T,T>
req
- the number of elements to requestprotected void doNormalNext(T ev)
doNormalNext
in class FallbackAction<T>
protected void doShutdown()
doShutdown
in class Action<T,T>
Copyright © 2017. All rights reserved.