public final class ConcatAction<T> extends Action<org.reactivestreams.Publisher<? extends T>,T>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
ConcatAction() |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Stop consuming signals from upstream.
|
protected void |
doNext(org.reactivestreams.Publisher<? extends T> ev) |
protected void |
doOnSubscribe(org.reactivestreams.Subscription subscription) |
void |
onComplete() |
protected void |
requestUpstream(long capacity,
boolean terminated,
long elements) |
void |
subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
--------------------------------------------------------------------------------------------------------
ACTION SIGNAL HANDLING
--------------------------------------------------------------------------------------------------------
|
protected void |
subscribeWithSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
PushSubscription<T> subscription)
Subscribe a given subscriber and pairs it with a given subscription instead of letting the Stream pick it
automatically.
|
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, 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, requestMore, 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
protected void doNext(org.reactivestreams.Publisher<? extends T> ev)
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<org.reactivestreams.Publisher<? extends T>>
onComplete
in class Action<org.reactivestreams.Publisher<? extends T>,T>
protected void doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class Action<org.reactivestreams.Publisher<? extends T>,T>
public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
Action
protected void requestUpstream(long capacity, boolean terminated, long elements)
requestUpstream
in class Action<org.reactivestreams.Publisher<? extends T>,T>
protected void subscribeWithSubscription(org.reactivestreams.Subscriber<? super T> subscriber, PushSubscription<T> subscription)
Action
This is mainly useful for libraries implementors, usually this#lift(reactor.fn.Supplier)
and
this#subscribe(org.reactivestreams.Subscriber)
are just fine.
subscribeWithSubscription
in class Action<org.reactivestreams.Publisher<? extends T>,T>
public void cancel()
Control
PushSubscription.terminated
flag.Copyright © 2017. All rights reserved.