reactor.core.publisher

类 FluxProcessor<IN,OUT>

java.lang.Object

reactor.core.publisher.Flux<OUT>

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

类型参数:

IN - the input value type

OUT - the output value type

所有已实现的接口:

org.reactivestreams.Processor<IN,OUT>, org.reactivestreams.Publisher<OUT>, org.reactivestreams.Subscriber<IN>, CorePublisher<OUT>, CoreSubscriber<IN>, Disposable, Scannable

直接已知子类:

DirectProcessor, EmitterProcessor, ReplayProcessor, UnicastProcessor

已过时。

Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives

@Deprecated
public abstract class FluxProcessor<IN,OUT>
extends Flux<OUT>
implements org.reactivestreams.Processor<IN,OUT>, CoreSubscriber<IN>, Scannable, Disposable

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

作者:

Stephane Maldini

嵌套类概要

从接口继承的嵌套类/接口 reactor.core.Scannable

Scannable.Attr<T>

从接口继承的嵌套类/接口 reactor.core.Disposable

Disposable.Composite, Disposable.Swap

字段概要

从接口继承的字段 reactor.core.Scannable

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

构造器概要

构造器

构造器和说明
FluxProcessor() 已过时。

方法概要

限定符和类型	方法和说明
Context	currentContext() 已过时。 Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
void	dispose() 已过时。 Cancel or dispose the underlying task or resource.
long	downstreamCount() 已过时。 Return the number of active Subscriber or -1 if untracked.
int	getBufferSize() 已过时。 Return the processor buffer capacity if any or Integer.MAX_VALUE
java.lang.Throwable	getError() 已过时。 Current error if any, default to null
boolean	hasCompleted() 已过时。 Return true if terminated with onComplete
boolean	hasDownstreams() 已过时。 Return true if any Subscriber is actively subscribed
boolean	hasError() 已过时。 Return true if terminated with onError
java.util.stream.Stream<? extends Scannable>	inners() 已过时。 Return a Stream of referenced inners (flatmap, multicast etc)
boolean	isSerialized() 已过时。 Return true if this FluxProcessor supports multithread producing
boolean	isTerminated() 已过时。 Has this upstream finished or "completed" / "failed" ?
java.lang.Object	scanUnsafe(Scannable.Attr key) 已过时。 This method is used internally by components to define their key-value mappings in a single place.
FluxProcessor<IN,OUT>	serialize() 已过时。 Create a FluxProcessor that safely gates multi-threaded producer Subscriber.onNext(Object).
FluxSink<IN>	sink() 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
FluxSink<IN>	sink(FluxSink.OverflowStrategy strategy) 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
static <T> FluxProcessor<org.reactivestreams.Publisher<? extends T>,T>	switchOnNext() 已过时。 should use Sinks, Sinks.Many.asFlux() and Flux.switchOnNext(Publisher). To be removed in 3.5.0.
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.

从类继承的方法 reactor.core.publisher.Flux

all, any, as, blockFirst, blockFirst, blockLast, blockLast, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferUntil, bufferUntil, bufferUntilChanged, bufferUntilChanged, bufferUntilChanged, bufferWhen, bufferWhen, bufferWhile, cache, cache, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, contextCapture, contextWrite, contextWrite, count, create, create, defaultIfEmpty, defer, deferContextual, delayElements, delayElements, delaySequence, delaySequence, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, distinct, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnComplete, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, mapNotNull, materialize, merge, merge, merge, merge, merge, merge, mergeComparing, mergeComparing, mergeComparing, mergeComparingDelayError, mergeComparingWith, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, mergePriority, mergePriority, mergePriority, mergePriorityDelayError, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequentialDelayError, mergeSequentialDelayError, mergeSequentialDelayError, mergeWith, metrics, name, never, next, ofType, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, publishOn, push, push, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replay, replay, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, shareNext, single, single, singleOrEmpty, skip, skip, skip, skipLast, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, tap, tap, tap, then, then, thenEmpty, thenMany, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowUntilChanged, windowUntilChanged, windowUntilChanged, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterable

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

从接口继承的方法 org.reactivestreams.Publisher

subscribe

从接口继承的方法 reactor.core.CoreSubscriber

onSubscribe

从接口继承的方法 org.reactivestreams.Subscriber

onComplete, onError, onNext

从接口继承的方法 reactor.core.Scannable

actuals, from, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated

从接口继承的方法 reactor.core.Disposable

isDisposed

构造器详细资料

FluxProcessor

public FluxProcessor()

已过时。

方法详细资料

switchOnNext

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

已过时。 should use Sinks, Sinks.Many.asFlux() and Flux.switchOnNext(Publisher). To be removed in 3.5.0.

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.

类型参数:

T - the produced type

返回:

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.

类型参数:

IN - the receiving type

OUT - the producing type

参数:

upstream - the upstream subscriber

downstream - the downstream publisher

返回:

a new blackboxed FluxProcessor

dispose

public void dispose()

已过时。

从接口复制的说明: Disposable

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

指定者:

dispose 在接口中 Disposable

downstreamCount

public long downstreamCount()

已过时。

Return the number of active Subscriber or -1 if untracked.

返回:

the number of active Subscriber or -1 if untracked

getBufferSize

public int getBufferSize()

已过时。

Return the processor buffer capacity if any or Integer.MAX_VALUE

返回:

processor buffer capacity if any or Integer.MAX_VALUE

getError

@Nullable
public java.lang.Throwable getError()

已过时。

Current error if any, default to null

返回:

Current error if any, default to null

hasDownstreams

public boolean hasDownstreams()

已过时。

Return true if any Subscriber is actively subscribed

返回:

true if any Subscriber is actively subscribed

hasCompleted

public final boolean hasCompleted()

已过时。

Return true if terminated with onComplete

返回:

true if terminated with onComplete

hasError

public final boolean hasError()

已过时。

Return true if terminated with onError

返回:

true if terminated with onError

inners

public java.util.stream.Stream<? extends Scannable> inners()

已过时。

从接口复制的说明: Scannable

Return a Stream of referenced inners (flatmap, multicast etc)

指定者:

inners 在接口中 Scannable

返回:

a Stream of referenced inners (flatmap, multicast etc)

isTerminated

public boolean isTerminated()

已过时。

Has this upstream finished or "completed" / "failed" ?

返回:

has this upstream finished or "completed" / "failed" ?

isSerialized

public boolean isSerialized()

已过时。

Return true if this FluxProcessor supports multithread producing

返回:

true if this FluxProcessor supports multithread producing

scanUnsafe

@Nullable
public java.lang.Object scanUnsafe(Scannable.Attr key)

已过时。

从接口复制的说明: Scannable

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Scannable.Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using Scannable.scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

指定者:

scanUnsafe 在接口中 Scannable

参数:

key - a Scannable.Attr to resolve for the component.

返回:

the value associated to the key for that specific component, or null if none.

currentContext

public Context currentContext()

已过时。

从接口复制的说明: CoreSubscriber

Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.

指定者:

currentContext 在接口中 CoreSubscriber<IN>

返回:

a resolved context or Context.empty()

serialize

public final FluxProcessor<IN,OUT> serialize()

已过时。

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

Discard Support: The resulting processor discards elements received from the source Publisher (if any) when it cancels subscription to said source.

返回:

a serializing FluxProcessor

sink

@Deprecated
public final FluxSink<IN> sink()

已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.

Create a FluxSink that safely gates multi-threaded producer Subscriber.onNext(Object). This processor will be subscribed to that FluxSink, and any previous subscribers will be unsubscribed.

The returned FluxSink will not apply any FluxSink.OverflowStrategy and overflowing FluxSink.next(Object) will behave in two possible ways depending on the Processor:

• an unbounded processor will handle the overflow itself by dropping or buffering
• a bounded processor will block/spin

返回:

a serializing FluxSink

sink

@Deprecated
public final FluxSink<IN> sink(FluxSink.OverflowStrategy strategy)

已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.

Create a FluxSink that safely gates multi-threaded producer Subscriber.onNext(Object). This processor will be subscribed to that FluxSink, and any previous subscribers will be unsubscribed.

The returned FluxSink will not apply any FluxSink.OverflowStrategy and overflowing FluxSink.next(Object) will behave in two possible ways depending on the Processor:

• an unbounded processor will handle the overflow itself by dropping or buffering
• a bounded processor will block/spin on IGNORE strategy, or apply the strategy behavior

参数:

strategy - the overflow strategy, see FluxSink.OverflowStrategy for the available strategies

返回:

a serializing FluxSink