public final class MergeAction<O> extends FanInAction<O,O,O,MergeAction.InnerSubscriber<O>>
Modifier and Type | Class and Description |
---|---|
static class |
MergeAction.InnerSubscriber<I> |
COMPLETING, dispatcher, NOT_STARTED, RUNNING
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
MergeAction(Dispatcher dispatcher) |
MergeAction(Dispatcher dispatcher,
List<? extends org.reactivestreams.Publisher<? extends O>> publishers) |
Modifier and Type | Method and Description |
---|---|
protected MergeAction.InnerSubscriber<O> |
createSubscriber() |
protected void |
doNext(O ev) |
addPublisher, cancel, checkDynamicMerge, createFanInSubscription, doOnSubscribe, dynamicMergeAction, getDispatcher, getSubscription, initUpstreamPublisherAndCapacity, onNext, requestMore, requestUpstream, scheduleCompletion, subscribe, toString
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doComplete, 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
public MergeAction(Dispatcher dispatcher)
public MergeAction(Dispatcher dispatcher, List<? extends org.reactivestreams.Publisher<? extends O>> publishers)
protected MergeAction.InnerSubscriber<O> createSubscriber()
createSubscriber
in class FanInAction<O,O,O,MergeAction.InnerSubscriber<O>>
Copyright © 2016. All rights reserved.