public final class CompositeAction<E,O> extends Action<E,O>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
CompositeAction(Action<E,?> head,
Action<?,O> tail) |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Stop consuming signals from upstream.
|
Action<E,O> |
capacity(long elements)
--------------------------------------------------------------------------------------------------------
ACTION MODIFIERS
--------------------------------------------------------------------------------------------------------
|
StreamUtils.StreamVisitor |
debug()
Print a debugged form of the root action relative to this one.
|
protected void |
doNext(E ev) |
Action<E,?> |
input() |
void |
onComplete() |
void |
onError(Throwable t) |
void |
onNext(E e) |
void |
onSubscribe(org.reactivestreams.Subscription s) |
Stream<O> |
output() |
void |
subscribe(org.reactivestreams.Subscriber<? super O> s)
--------------------------------------------------------------------------------------------------------
ACTION SIGNAL HANDLING
--------------------------------------------------------------------------------------------------------
|
String |
toString() |
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancelSubscription, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, doComplete, doError, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onOverflowBuffer, recycle, requestAll, requestMore, requestUpstream, 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
public void subscribe(org.reactivestreams.Subscriber<? super O> s)
Action
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe
in interface org.reactivestreams.Subscriber<E>
onSubscribe
in class Action<E,O>
public void onNext(E e)
public void onError(Throwable t)
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<E>
onComplete
in class Action<E,O>
public StreamUtils.StreamVisitor debug()
Action
public Action<E,O> capacity(long elements)
Action
public void cancel()
Control
PushSubscription.terminated
flag.Copyright © 2017. All rights reserved.