public class DynamicMergeAction<I,O> extends Action<org.reactivestreams.Publisher<? extends I>,O>
Modifier and Type | Field and Description |
---|---|
protected static AtomicLongFieldUpdater<DynamicMergeAction> |
REQUESTED_UPDATER |
protected static AtomicIntegerFieldUpdater<DynamicMergeAction> |
WIP_UPDATER |
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
DynamicMergeAction(FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> fanInAction) |
Modifier and Type | Method and Description |
---|---|
Action<org.reactivestreams.Publisher<? extends I>,O> |
capacity(long elements)
--------------------------------------------------------------------------------------------------------
ACTION MODIFIERS
--------------------------------------------------------------------------------------------------------
|
protected PushSubscription<O> |
createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
boolean reactivePull) |
int |
decrementWip() |
protected void |
doNext(org.reactivestreams.Publisher<? extends I> ev) |
FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> |
mergedStream() |
void |
onComplete() |
void |
onError(Throwable cause) |
void |
onNext(org.reactivestreams.Publisher<? extends I> value) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
void |
requestMore(long n)
Request the next n elements from the source
|
protected void |
requestUpstream(long capacity,
boolean terminated,
long elements) |
void |
subscribe(org.reactivestreams.Subscriber<? super O> subscriber)
--------------------------------------------------------------------------------------------------------
ACTION SIGNAL HANDLING
--------------------------------------------------------------------------------------------------------
|
String |
toString() |
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, checkRequest, combine, control, createSubscription, createTrackingSubscription, debug, doComplete, doError, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onOverflowBuffer, recycle, requestAll, 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
protected static final AtomicIntegerFieldUpdater<DynamicMergeAction> WIP_UPDATER
protected static final AtomicLongFieldUpdater<DynamicMergeAction> REQUESTED_UPDATER
public DynamicMergeAction(FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> fanInAction)
public void subscribe(org.reactivestreams.Subscriber<? super O> subscriber)
Action
protected PushSubscription<O> createSubscription(org.reactivestreams.Subscriber<? super O> subscriber, boolean reactivePull)
createSubscription
in class Action<org.reactivestreams.Publisher<? extends I>,O>
public void requestMore(long n)
Control
requestMore
in interface Control
requestMore
in class Action<org.reactivestreams.Publisher<? extends I>,O>
n
- the number of elements to requestprotected void doNext(org.reactivestreams.Publisher<? extends I> ev)
public void onNext(org.reactivestreams.Publisher<? extends I> value)
public void onSubscribe(org.reactivestreams.Subscription subscription)
onSubscribe
in interface org.reactivestreams.Subscriber<org.reactivestreams.Publisher<? extends I>>
onSubscribe
in class Action<org.reactivestreams.Publisher<? extends I>,O>
protected void requestUpstream(long capacity, boolean terminated, long elements)
requestUpstream
in class Action<org.reactivestreams.Publisher<? extends I>,O>
public void onError(Throwable cause)
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<org.reactivestreams.Publisher<? extends I>>
onComplete
in class Action<org.reactivestreams.Publisher<? extends I>,O>
public Action<org.reactivestreams.Publisher<? extends I>,O> capacity(long elements)
Action
public int decrementWip()
public FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> mergedStream()
Copyright © 2016. All rights reserved.