public class SwitchAction<T> extends Action<org.reactivestreams.Publisher<? extends T>,T>
Modifier and Type | Class and Description |
---|---|
class |
SwitchAction.SwitchSubscriber |
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
SwitchAction(Dispatcher dispatcher) |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Stop consuming signals from upstream.
|
protected void |
doComplete() |
protected void |
doNext(org.reactivestreams.Publisher<? extends T> ev) |
protected void |
doShutdown() |
Dispatcher |
getDispatcher()
Get the dispatcher used to execute signals on this Stream instance.
|
SwitchAction.SwitchSubscriber |
getSwitchSubscriber() |
void |
onNext(org.reactivestreams.Publisher<? extends T> ev) |
protected void |
requestUpstream(long capacity,
boolean terminated,
long elements) |
void |
subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
--------------------------------------------------------------------------------------------------------
ACTION SIGNAL HANDLING
--------------------------------------------------------------------------------------------------------
|
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doError, doOnSubscribe, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, 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 SwitchAction(Dispatcher dispatcher)
public SwitchAction.SwitchSubscriber getSwitchSubscriber()
public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
Action
public void onNext(org.reactivestreams.Publisher<? extends T> ev)
public void cancel()
Control
PushSubscription.terminated
flag.protected void doNext(org.reactivestreams.Publisher<? extends T> ev)
protected void doShutdown()
doShutdown
in class Action<org.reactivestreams.Publisher<? extends T>,T>
protected void doComplete()
doComplete
in class Action<org.reactivestreams.Publisher<? extends T>,T>
protected void requestUpstream(long capacity, boolean terminated, long elements)
requestUpstream
in class Action<org.reactivestreams.Publisher<? extends T>,T>
public final Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<T>
Copyright © 2016. All rights reserved.