reactor.core.publisher

类 MonoProcessor<O>

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoProcessor<O>

类型参数:

O - the type of the value that will be made available

所有已实现的接口:

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

已过时。

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

@Deprecated
public abstract class MonoProcessor<O>
extends Mono<O>
implements org.reactivestreams.Processor<O,O>, CoreSubscriber<O>, Disposable, org.reactivestreams.Subscription, Scannable

A MonoProcessor is a Processor that is also a Mono.

Implementations might implements stateful semantics, allowing multiple subscriptions. Once a MonoProcessor has been resolved, implementations may also replay cached signals to newer subscribers.

Despite having default implementations, most methods should be reimplemented with meaningful semantics relevant to concrete child classes.

作者:

Stephane Maldini

嵌套类概要

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

Disposable.Composite, Disposable.Swap

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

Scannable.Attr<T>

字段概要

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

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
O	block() 已过时。 Block the calling thread indefinitely, waiting for the completion of this MonoProcessor.
O	block(java.time.Duration timeout) 已过时。 Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.
void	cancel() 已过时。 the MonoProcessor will cease to implement Subscription in 3.5
static <T> MonoProcessor<T>	create() 已过时。 Use Sinks.one(), to be removed in 3.5
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.
java.lang.Throwable	getError() 已过时。 Return the produced Throwable error if any or null
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	isCancelled() 已过时。 the MonoProcessor will cease to implement Subscription and this method will be removed in 3.5
boolean	isDisposed() 已过时。 Optionally return true when the resource or task is disposed.
boolean	isError() 已过时。 Indicates whether this MonoProcessor has been completed with an error.
boolean	isSuccess() 已过时。 Indicates whether this MonoProcessor has been successfully completed a value.
boolean	isTerminated() 已过时。 Indicates whether this MonoProcessor has been terminated by the source producer with a success or an error.
O	peek() 已过时。 this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture
void	request(long n) 已过时。 the MonoProcessor will cease to implement Subscription in 3.5
java.lang.Object	scanUnsafe(Scannable.Attr key) 已过时。 This method is used internally by components to define their key-value mappings in a single place.

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

and, as, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextCapture, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, mapNotNull, materialize, mergeWith, metrics, name, never, ofType, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, share, single, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, tap, tap, tap, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, when, when, whenDelayError, whenDelayError, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipWhen, zipWhen, zipWith, zipWith

从类继承的方法 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

构造器详细资料

MonoProcessor

public MonoProcessor()

已过时。

方法详细资料

create

@Deprecated
public static <T> MonoProcessor<T> create()

已过时。 Use Sinks.one(), to be removed in 3.5

Create a MonoProcessor that will eagerly request 1 on Subscriber.onSubscribe(Subscription), cache and emit the eventual result for 1 or N subscribers.

类型参数:

T - type of the expected value

返回:

A MonoProcessor.

cancel

@Deprecated
public void cancel()

已过时。 the MonoProcessor will cease to implement Subscription in 3.5

指定者:

cancel 在接口中 org.reactivestreams.Subscription

isCancelled

@Deprecated
public boolean isCancelled()

已过时。 the MonoProcessor will cease to implement Subscription and this method will be removed in 3.5

Indicates whether this MonoProcessor has been interrupted via cancellation.

返回:

true if this MonoProcessor is cancelled, false otherwise.

request

@Deprecated
public void request(long n)

已过时。 the MonoProcessor will cease to implement Subscription in 3.5

指定者:

request 在接口中 org.reactivestreams.Subscription

参数:

n - the request amount

dispose

public void dispose()

已过时。

从接口复制的说明: Disposable

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

指定者:

dispose 在接口中 Disposable

block

@Nullable
public O block()

已过时。

Block the calling thread indefinitely, waiting for the completion of this MonoProcessor. If the MonoProcessor is completed with an error a RuntimeException that wraps the error is thrown.

覆盖:

block 在类中 Mono<O>

返回:

the value of this MonoProcessor

block

@Nullable
public O block(@Nullable
                          java.time.Duration timeout)

已过时。

Block the calling thread for the specified time, waiting for the completion of this MonoProcessor. If the MonoProcessor is completed with an error a RuntimeException that wraps the error is thrown.

覆盖:

block 在类中 Mono<O>

参数:

timeout - the timeout value as a Duration

返回:

the value of this MonoProcessor or null if the timeout is reached and the MonoProcessor has not completed

getError

@Nullable
public java.lang.Throwable getError()

已过时。

Return the produced Throwable error if any or null

返回:

the produced Throwable error if any or null

isError

public final boolean isError()

已过时。

Indicates whether this MonoProcessor has been completed with an error.

返回:

true if this MonoProcessor was completed with an error, false otherwise.

isSuccess

public final boolean isSuccess()

已过时。

Indicates whether this MonoProcessor has been successfully completed a value.

返回:

true if this MonoProcessor is successful, false otherwise.

isTerminated

public boolean isTerminated()

已过时。

Indicates whether this MonoProcessor has been terminated by the source producer with a success or an error.

返回:

true if this MonoProcessor is successful, false otherwise.

isDisposed

public boolean isDisposed()

已过时。

从接口复制的说明: Disposable

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

指定者:

isDisposed 在接口中 Disposable

返回:

true when there's a guarantee the resource or task is disposed.

peek

@Nullable
 @Deprecated
public O peek()

已过时。 this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture

Returns the value that completed this MonoProcessor. Returns null if the MonoProcessor has not been completed. If the MonoProcessor is completed with an error a RuntimeException that wraps the error is thrown.

返回:

the value that completed the MonoProcessor, or null if it has not been completed

抛出:

java.lang.RuntimeException - if the MonoProcessor was completed with an error

currentContext

public Context currentContext()

已过时。

从接口复制的说明: CoreSubscriber

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

指定者:

currentContext 在接口中 CoreSubscriber<O>

返回:

a resolved context or Context.empty()

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.

downstreamCount

public long downstreamCount()

已过时。

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

返回:

the number of active Subscriber or -1 if untracked

hasDownstreams

public final boolean hasDownstreams()

已过时。

Return true if any Subscriber is actively subscribed

返回:

true if any Subscriber is actively subscribed

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)