public class RepeatWhenAction<T> extends Action<T,T>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
RepeatWhenAction(Dispatcher dispatcher,
Function<? super Stream<? extends Long>,? extends org.reactivestreams.Publisher<?>> predicate,
org.reactivestreams.Publisher<? extends T> rootPublisher) |
Modifier and Type | Method and Description |
---|---|
protected void |
doComplete() |
protected void |
doNext(T ev) |
protected void |
doOnSubscribe(org.reactivestreams.Subscription subscription) |
protected void |
doRetry() |
Dispatcher |
getDispatcher()
Get the dispatcher used to execute signals on this Stream instance.
|
void |
onComplete() |
void |
requestMore(long n)
Request the next n elements from the source
|
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doError, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestUpstream, 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, 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 RepeatWhenAction(Dispatcher dispatcher, Function<? super Stream<? extends Long>,? extends org.reactivestreams.Publisher<?>> predicate, org.reactivestreams.Publisher<? extends T> rootPublisher)
protected void doComplete()
doComplete
in class Action<T,T>
public void requestMore(long n)
Control
requestMore
in interface Control
requestMore
in class Action<T,T>
n
- the number of elements to requestprotected void doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class Action<T,T>
protected void doRetry()
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>
onComplete
in class Action<T,T>
public final Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<T>
Copyright © 2016. All rights reserved.