DirectProcessor (reactor-3)

java.lang.Object
- reactor.core.publisher.Flux<OUT>
- - reactor.core.publisher.FluxProcessor<T,T>
  - - reactor.core.publisher.DirectProcessor<T>

类型参数:

T - the input and output value type

所有已实现的接口:

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

已过时。
To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
```
@Deprecated
public final class DirectProcessor<T>
extends FluxProcessor<T,T>
```
Dispatches onNext, onError and onComplete signals to zero-to-many Subscribers. Please note, that along with multiple consumers, current implementation of DirectProcessor supports multiple producers. However, all producers must produce messages on the same Thread, otherwise Reactive Streams Spec contract is violated.

Note: DirectProcessor does not coordinate backpressure between its Subscribers and the upstream, but consumes its upstream in an unbounded manner. In the case where a downstream Subscriber is not ready to receive items (hasn't requested yet or enough), it will be terminated with an IllegalStateException. Hence in terms of interaction model, DirectProcessor only supports PUSH from the source through the processor to the Subscribers.

Note: If there are no Subscribers, upstream items are dropped and only the terminal events are retained. A terminated DirectProcessor will emit the terminal signal to late subscribers.

Note: The implementation ignores Subscriptions set via onSubscribe.

嵌套类概要
- 从接口继承的嵌套类/接口 reactor.core.Scannable
  Scannable.Attr<T>
- 从接口继承的嵌套类/接口 reactor.core.Disposable
  Disposable.Composite, Disposable.Swap

字段概要
- 从接口继承的字段 reactor.core.Scannable
  OPERATOR_NAME_UNRELATED_WORDS_PATTERN

方法概要

所有方法静态方法实例方法具体方法已过时的方法
限定符和类型	方法和说明
`boolean`	`add(reactor.core.publisher.SinkManyBestEffort.DirectInner<T> s)` 已过时。 Add a new `SinkManyBestEffort.DirectInner` to this publisher.
`static <E> DirectProcessor<E>`	`create()` 已过时。 To be removed in 3.5. Closest sink is `Sinks.many().multicast().directBestEffort()`, except it doesn't terminate overflowing downstreams.
`Context`	`currentContext()` 已过时。 Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `Subscriber`.
`long`	`downstreamCount()` 已过时。 Return the number of active `Subscriber` or -1 if untracked.
`java.lang.Throwable`	`getError()` 已过时。 Current error if any, default to null
`int`	`getPrefetch()` 已过时。 The prefetch configuration of the `Flux`
`boolean`	`hasDownstreams()` 已过时。 Return true if any `Subscriber` is actively subscribed
`java.util.stream.Stream<? extends Scannable>`	`inners()` 已过时。 Return a `Stream` of referenced inners (flatmap, multicast etc)
`boolean`	`isTerminated()` 已过时。 Has this upstream finished or "completed" / "failed" ?
`void`	`onComplete()` 已过时。
`void`	`onError(java.lang.Throwable throwable)` 已过时。
`void`	`onNext(T t)` 已过时。
`void`	`onSubscribe(org.reactivestreams.Subscription s)` 已过时。 Implementors should initialize any state used by `Subscriber.onNext(Object)` before calling `Subscription.request(long)`.
`void`	`remove(reactor.core.publisher.SinkManyBestEffort.DirectInner<T> s)` 已过时。 Remove an `SinkManyBestEffort.DirectInner` from this publisher.
`void`	`subscribe(CoreSubscriber<? super T> actual)` 已过时。 An internal `Publisher.subscribe(Subscriber)` that will bypass `Hooks.onLastOperator(Function)` pointcut.

从类继承的方法 reactor.core.publisher.FluxProcessor
dispose, getBufferSize, hasCompleted, hasError, isSerialized, scanUnsafe, serialize, sink, sink, switchOnNext, wrap

从类继承的方法 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, 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, 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.Scannable
actuals, from, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated

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

- 方法详细资料
  - create
```
@Deprecated
public static <E> DirectProcessor<E> create()
```
    已过时。 To be removed in 3.5. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
    
    Create a new DirectProcessor
    
    类型参数:
    
    E - Type of processed signals
    
    返回:
    
    a fresh processor
  - getPrefetch
```
public int getPrefetch()
```
    已过时。
    
    从类复制的说明: Flux
    
    The prefetch configuration of the Flux
    
    覆盖:
    
    getPrefetch 在类中 Flux<T>
    
    返回:
    
    the prefetch configuration of the Flux, -1 if unspecified
  - currentContext
```
public Context currentContext()
```
    已过时。
    
    从接口复制的说明: CoreSubscriber
    
    Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
    
    指定者:
    
    currentContext 在接口中 CoreSubscriber<T>
    
    覆盖:
    
    currentContext 在类中 FluxProcessor<T,T>
    
    返回:
    
    a resolved context or Context.empty()
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription s)
```
    已过时。
    
    从接口复制的说明: CoreSubscriber
    
    Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long). Should further onNext related state modification occur, thread-safety will be required.
    Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled Logger.
    
    指定者:
    
    onSubscribe 在接口中 org.reactivestreams.Subscriber<T>
    
    指定者:
    
    onSubscribe 在接口中 CoreSubscriber<T>
  - onComplete
```
public void onComplete()
```
    已过时。
    
    指定者:
    
    onComplete 在接口中 org.reactivestreams.Subscriber<T>
  - onError
```
public void onError(java.lang.Throwable throwable)
```
    已过时。
    
    指定者:
    
    onError 在接口中 org.reactivestreams.Subscriber<T>
  - onNext
```
public void onNext(T t)
```
    已过时。
    
    指定者:
    
    onNext 在接口中 org.reactivestreams.Subscriber<T>
  - subscribe
```
public void subscribe(CoreSubscriber<? super T> actual)
```
    已过时。
    
    从类复制的说明: Flux
    
    An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.
    In addition to behave as expected by Publisher.subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.
    
    指定者:
    
    subscribe 在接口中 CorePublisher<T>
    
    指定者:
    
    subscribe 在类中 Flux<T>
    
    参数:
    
    actual - the Subscriber interested into the published sequence
    
    另请参阅:
    
    Flux.subscribe(Subscriber)
  - inners
```
public java.util.stream.Stream<? extends Scannable> inners()
```
    已过时。
    
    从接口复制的说明: Scannable
    
    Return a Stream of referenced inners (flatmap, multicast etc)
    
    指定者:
    
    inners 在接口中 Scannable
    
    覆盖:
    
    inners 在类中 FluxProcessor<T,T>
    
    返回:
    
    a Stream of referenced inners (flatmap, multicast etc)
  - isTerminated
```
public boolean isTerminated()
```
    已过时。
    
    从类复制的说明: FluxProcessor
    
    Has this upstream finished or "completed" / "failed" ?
    
    覆盖:
    
    isTerminated 在类中 FluxProcessor<T,T>
    
    返回:
    
    has this upstream finished or "completed" / "failed" ?
  - downstreamCount
```
public long downstreamCount()
```
    已过时。
    
    从类复制的说明: FluxProcessor
    
    Return the number of active Subscriber or -1 if untracked.
    
    覆盖:
    
    downstreamCount 在类中 FluxProcessor<T,T>
    
    返回:
    
    the number of active Subscriber or -1 if untracked
  - add
```
public boolean add(reactor.core.publisher.SinkManyBestEffort.DirectInner<T> s)
```
    已过时。
    
    Add a new SinkManyBestEffort.DirectInner to this publisher.
    
    参数:
    
    s - the new SinkManyBestEffort.DirectInner to add
    
    返回:
    
    true if the inner could be added, false if the publisher cannot accept new subscribers
  - remove
```
public void remove(reactor.core.publisher.SinkManyBestEffort.DirectInner<T> s)
```
    已过时。
    
    Remove an SinkManyBestEffort.DirectInner from this publisher. Does nothing if the inner is not currently managed by the publisher.
    
    参数:
    
    s - the SinkManyBestEffort.DirectInner to remove
  - hasDownstreams
```
public boolean hasDownstreams()
```
    已过时。
    
    从类复制的说明: FluxProcessor
    
    Return true if any Subscriber is actively subscribed
    
    覆盖:
    
    hasDownstreams 在类中 FluxProcessor<T,T>
    
    返回:
    
    true if any Subscriber is actively subscribed
  - getError
```
@Nullable
public java.lang.Throwable getError()
```
    已过时。
    
    从类复制的说明: FluxProcessor
    
    Current error if any, default to null
    
    覆盖:
    
    getError 在类中 FluxProcessor<T,T>
    
    返回:
    
    Current error if any, default to null

类 DirectProcessor<T>

嵌套类概要

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

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

字段概要

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

方法概要

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

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

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

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

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

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

方法详细资料

create

getPrefetch

currentContext

onSubscribe

onComplete

onError

onNext

subscribe

inners

isTerminated

downstreamCount

add

remove

hasDownstreams

getError