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