public final class CombineLatestAction<O,V,TUPLE extends Tuple> extends FanInAction<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>>
Modifier and Type | Class and Description |
---|---|
static class |
CombineLatestAction.InnerSubscriber<O,V> |
static class |
CombineLatestAction.Zippable<O> |
COMPLETING, dispatcher, NOT_STARTED, RUNNING
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
CombineLatestAction(Dispatcher dispatcher,
Function<TUPLE,? extends V> accumulator,
List<? extends org.reactivestreams.Publisher<? extends O>> composables) |
Modifier and Type | Method and Description |
---|---|
protected void |
broadcastTuple() |
protected FanInSubscription<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>> |
createFanInSubscription() |
protected CombineLatestAction.InnerSubscriber<O,V> |
createSubscriber() |
protected PushSubscription<CombineLatestAction.Zippable<O>> |
createTrackingSubscription(org.reactivestreams.Subscription subscription) |
protected void |
doComplete() |
protected void |
doNext(CombineLatestAction.Zippable<O> ev) |
protected long |
initUpstreamPublisherAndCapacity() |
String |
toString() |
addPublisher, cancel, checkDynamicMerge, doOnSubscribe, dynamicMergeAction, getDispatcher, getSubscription, onNext, requestMore, requestUpstream, scheduleCompletion, subscribe
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, debug, doError, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, isPublishing, onComplete, onError, onOverflowBuffer, onSubscribe, 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, 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 broadcastTuple()
protected FanInSubscription<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>> createFanInSubscription()
createFanInSubscription
in class FanInAction<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>>
protected PushSubscription<CombineLatestAction.Zippable<O>> createTrackingSubscription(org.reactivestreams.Subscription subscription)
createTrackingSubscription
in class Action<CombineLatestAction.Zippable<O>,V>
protected void doNext(CombineLatestAction.Zippable<O> ev)
doNext
in class Action<CombineLatestAction.Zippable<O>,V>
protected void doComplete()
doComplete
in class Action<CombineLatestAction.Zippable<O>,V>
protected CombineLatestAction.InnerSubscriber<O,V> createSubscriber()
createSubscriber
in class FanInAction<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>>
protected long initUpstreamPublisherAndCapacity()
initUpstreamPublisherAndCapacity
in class FanInAction<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>>
public String toString()
toString
in class FanInAction<O,CombineLatestAction.Zippable<O>,V,CombineLatestAction.InnerSubscriber<O,V>>
Copyright © 2017. All rights reserved.