public final class ZipAction<O,V,TUPLE extends Tuple> extends FanInAction<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>>
Modifier and Type | Class and Description |
---|---|
static class |
ZipAction.InnerSubscriber<O,V> |
static class |
ZipAction.Zippable<O> |
COMPLETING, dispatcher, NOT_STARTED, RUNNING
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
ZipAction(Dispatcher dispatcher,
Function<TUPLE,? extends V> accumulator,
List<? extends org.reactivestreams.Publisher<? extends O>> composables) |
Modifier and Type | Method and Description |
---|---|
protected void |
broadcastTuple(boolean isFinishing) |
protected FanInSubscription<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>> |
createFanInSubscription() |
protected ZipAction.InnerSubscriber<O,V> |
createSubscriber() |
protected PushSubscription<ZipAction.Zippable<O>> |
createTrackingSubscription(org.reactivestreams.Subscription subscription) |
protected void |
doComplete() |
protected void |
doNext(ZipAction.Zippable<O> ev) |
protected void |
doOnSubscribe(org.reactivestreams.Subscription subscription) |
static <TUPLE extends Tuple,V> |
joinZipper() |
protected void |
requestUpstream(long capacity,
boolean terminated,
long elements) |
String |
toString() |
addPublisher, cancel, checkDynamicMerge, dynamicMergeAction, getDispatcher, getSubscription, initUpstreamPublisherAndCapacity, onNext, requestMore, 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 doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class FanInAction<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>>
protected void broadcastTuple(boolean isFinishing)
protected void requestUpstream(long capacity, boolean terminated, long elements)
requestUpstream
in class FanInAction<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>>
protected FanInSubscription<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>> createFanInSubscription()
createFanInSubscription
in class FanInAction<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>>
protected PushSubscription<ZipAction.Zippable<O>> createTrackingSubscription(org.reactivestreams.Subscription subscription)
createTrackingSubscription
in class Action<ZipAction.Zippable<O>,V>
protected void doNext(ZipAction.Zippable<O> ev)
doNext
in class Action<ZipAction.Zippable<O>,V>
protected void doComplete()
doComplete
in class Action<ZipAction.Zippable<O>,V>
protected ZipAction.InnerSubscriber<O,V> createSubscriber()
createSubscriber
in class FanInAction<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>>
public String toString()
toString
in class FanInAction<O,ZipAction.Zippable<O>,V,ZipAction.InnerSubscriber<O,V>>
Copyright © 2016. All rights reserved.