public class CacheAction<T> extends Action<T,T>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
CacheAction() |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<T> |
createSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
CompletableQueue<T> queue) |
protected void |
doComplete() |
protected void |
doError(Throwable ev) |
void |
doNext(T value) |
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, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createTrackingSubscription, debug, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, requestUpstream, subscribe, 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 PushSubscription<T> createSubscription(org.reactivestreams.Subscriber<? super T> subscriber, CompletableQueue<T> queue)
createSubscription
in class Action<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<T,T>
protected void doComplete()
doComplete
in class Action<T,T>
Copyright © 2016. All rights reserved.