public class RepeatAction<T> extends Action<T,T>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
RepeatAction(Dispatcher dispatcher,
int numRetries,
org.reactivestreams.Publisher<? extends T> parentStream) |
Modifier and Type | Method and Description |
---|---|
protected void |
doNext(T ev) |
protected void |
doOnSubscribe(org.reactivestreams.Subscription subscription) |
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, doComplete, 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 RepeatAction(Dispatcher dispatcher, int numRetries, org.reactivestreams.Publisher<? extends T> parentStream)
protected void doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class Action<T,T>
public final Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<T>
public void requestMore(long n)
Control
requestMore
in interface Control
requestMore
in class Action<T,T>
n
- the number of elements to requestpublic void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>
onComplete
in class Action<T,T>
Copyright © 2016. All rights reserved.