reactor.core.publisher

Class FluxProcessor<IN,OUT>

java.lang.Object

reactor.core.publisher.Flux<OUT>

reactor.core.publisher.FluxProcessor<IN,OUT>

Type Parameters:

IN - the input value type

OUT - the output value type

All Implemented Interfaces:

org.reactivestreams.Processor<IN,OUT>, org.reactivestreams.Publisher<OUT>, org.reactivestreams.Subscriber<IN>, Trackable

Direct Known Subclasses:

DirectProcessor, EmitterProcessor, ReplayProcessor, TopicProcessor, UnicastProcessor, WorkQueueProcessor

public abstract class FluxProcessor<IN,OUT>
extends Flux<OUT>
implements org.reactivestreams.Processor<IN,OUT>, Trackable

A base processor that exposes Flux API for Processor. Implementors include UnicastProcessor, EmitterProcessor, ReplayProcessor, WorkQueueProcessor and TopicProcessor.

Field Summary

Fields inherited from interface reactor.core.Trackable

UNSPECIFIED

Constructor Summary

Constructors

Constructor and Description
FluxProcessor()

Method Summary

Modifier and Type	Method and Description
FluxProcessor<IN,OUT>	connect() Trigger onSubscribe with a stateless subscription to signal this subscriber it can start receiving onNext, onComplete and onError calls.
BlockingSink<IN>	connectSink() Create a BlockingSink and attach it via Subscriber.onSubscribe(Subscription).
BlockingSink<IN>	connectSink(boolean autostart) Prepare a BlockingSink and pass it to Subscriber.onSubscribe(Subscription) if the autostart flag is set to true.
long	getCapacity() Return defined element capacity
FluxProcessor<IN,OUT>	serialize() Create a FluxProcessor that safely gates multi-threaded producer Subscriber.onNext(Object).
void	subscribe(org.reactivestreams.Subscriber<? super OUT> s)
static <T> FluxProcessor<org.reactivestreams.Publisher<? extends T>,T>	switchOnNext() Build a FluxProcessor whose data are emitted by the most recent emitted Publisher.
static <IN,OUT> FluxProcessor<IN,OUT>	wrap(org.reactivestreams.Subscriber<IN> upstream, org.reactivestreams.Publisher<OUT> downstream) Transform a receiving Subscriber and a producing Publisher in a logical FluxProcessor.

Methods inherited from class reactor.core.publisher.Flux

all, any, as, awaitOnSubscribe, blockFirst, blockFirst, blockFirstMillis, blockLast, blockLast, blockLastMillis, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferMillis, bufferMillis, bufferMillis, bufferMillis, bufferMillis, bufferMillis, bufferMillis, cache, cache, cache, cache, cancelOn, cast, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, compose, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, count, create, create, defaultIfEmpty, defer, delay, delayMillis, delayMillis, delaySubscription, delaySubscription, delaySubscriptionMillis, delaySubscriptionMillis, dematerialize, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doOnCancel, doOnComplete, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, filter, firstEmitting, firstEmitting, firstEmittingWith, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, from, fromArray, fromIterable, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, interval, interval, intervalMillis, intervalMillis, intervalMillis, intervalMillis, join, just, just, last, last, log, log, log, log, map, mapError, mapError, mapError, materialize, merge, merge, merge, merge, merge, merge, mergeWith, never, next, ofType, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorResumeWith, onErrorResumeWith, onErrorResumeWith, onErrorReturn, onErrorReturn, onErrorReturn, onTerminateDetach, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replayMillis, replayMillis, retry, retry, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleFirstMillis, sampleMillis, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, single, single, singleOrEmpty, skip, skip, skipLast, skipMillis, skipMillis, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnError, switchOnError, switchOnError, switchOnNext, switchOnNext, take, take, takeLast, takeMillis, takeMillis, takeUntil, takeUntilOther, takeWhile, then, then, then, thenMany, thenMany, timeout, timeout, timeout, timeout, timeout, timeoutMillis, timeoutMillis, timeoutMillis, timeoutMillis, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, using, using, window, window, window, window, window, window, window, window, windowMillis, windowMillis, windowMillis, windowMillis, windowMillis, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Methods inherited from interface reactor.core.Trackable

expectedFromUpstream, getError, getPending, isCancelled, isStarted, isTerminated, limit, requestedFromDownstream

Constructor Detail

FluxProcessor

public FluxProcessor()

Method Detail

switchOnNext

public static <T> FluxProcessor<org.reactivestreams.Publisher<? extends T>,T> switchOnNext()

Build a FluxProcessor whose data are emitted by the most recent emitted Publisher. The Flux will complete once both the publishers source and the last switched to Publisher have completed.

Type Parameters:

T - the produced type

Returns:

a FluxProcessor accepting publishers and producing T

wrap

public static <IN,OUT> FluxProcessor<IN,OUT> wrap(org.reactivestreams.Subscriber<IN> upstream,
                                                  org.reactivestreams.Publisher<OUT> downstream)

Transform a receiving Subscriber and a producing Publisher in a logical FluxProcessor. The link between the passed upstream and returned downstream will not be created automatically, e.g. not subscribed together. A Processor might choose to have orthogonal sequence input and output.

Type Parameters:

IN - the receiving type

OUT - the producing type

Parameters:

upstream - the upstream subscriber

downstream - the downstream publisher

Returns:

a new blackboxed FluxProcessor

connect

public FluxProcessor<IN,OUT> connect()

Trigger onSubscribe with a stateless subscription to signal this subscriber it can start receiving onNext, onComplete and onError calls.

Doing so MAY allow direct UNBOUNDED onXXX calls and MAY prevent Publisher to subscribe this subscriber. Note that Processor can extend this behavior to effectively start its subscribers.

Returns:

this

connectSink

public final BlockingSink<IN> connectSink()

Create a BlockingSink and attach it via Subscriber.onSubscribe(Subscription).

Returns:

a new subscribed BlockingSink

connectSink

public final BlockingSink<IN> connectSink(boolean autostart)

Prepare a BlockingSink and pass it to Subscriber.onSubscribe(Subscription) if the autostart flag is set to true.

Parameters:

autostart - automatically start?

Returns:

a new BlockingSink

getCapacity

public long getCapacity()

Description copied from interface: Trackable

Return defined element capacity

Specified by:

getCapacity in interface Trackable

Returns:

long capacity

serialize

public final FluxProcessor<IN,OUT> serialize()

Create a FluxProcessor that safely gates multi-threaded producer Subscriber.onNext(Object).

Returns:

a serializing FluxProcessor

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super OUT> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<OUT>