reactor.core.publisher

Class MonoProcessor<O>

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoProcessor<O>

Type Parameters:

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

All Implemented Interfaces:

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

Deprecated.

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 Processor<O,O>, CoreSubscriber<O>, Disposable, 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.

Author:

Stephane Maldini

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Disposable

Disposable.Composite, Disposable.Swap

Nested classes/interfaces inherited from interface reactor.core.Scannable

Scannable.Attr<T>

Field Summary

Fields inherited from interface reactor.core.Scannable

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Constructor Summary

Constructors

Constructor and Description
MonoProcessor() Deprecated.

Method Summary

Modifier and Type	Method and Description
O	block() Deprecated. Block the calling thread indefinitely, waiting for the completion of this MonoProcessor.
O	block(Duration timeout) Deprecated. Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.
void	cancel() Deprecated. the MonoProcessor will cease to implement Subscription in 3.5
static <T> MonoProcessor<T>	create() Deprecated. Use Sinks.one(), to be removed in 3.5
Context	currentContext() Deprecated. Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
void	dispose() Deprecated. Cancel or dispose the underlying task or resource.
long	downstreamCount() Deprecated. Return the number of active Subscriber or -1 if untracked.
Throwable	getError() Deprecated. Return the produced Throwable error if any or null
boolean	hasDownstreams() Deprecated. Return true if any Subscriber is actively subscribed
Stream<? extends Scannable>	inners() Deprecated. Return a Stream of referenced inners (flatmap, multicast etc)
boolean	isCancelled() Deprecated. the MonoProcessor will cease to implement Subscription and this method will be removed in 3.5
boolean	isDisposed() Deprecated. Optionally return true when the resource or task is disposed.
boolean	isError() Deprecated. Indicates whether this MonoProcessor has been completed with an error.
boolean	isSuccess() Deprecated. Indicates whether this MonoProcessor has been successfully completed a value.
boolean	isTerminated() Deprecated. Indicates whether this MonoProcessor has been terminated by the source producer with a success or an error.
O	peek() Deprecated. this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture
void	request(long n) Deprecated. the MonoProcessor will cease to implement Subscription in 3.5
Object	scanUnsafe(Scannable.Attr key) Deprecated. This method is used internally by components to define their key-value mappings in a single place.

Methods inherited from class 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, onAssembly, 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, singleOptional, 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, 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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Methods inherited from interface reactor.core.CoreSubscriber

onSubscribe

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext

Methods inherited from interface reactor.core.Scannable

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

Constructor Detail

MonoProcessor

public MonoProcessor()

Deprecated.

Method Detail

create

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

Deprecated. 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.

Type Parameters:

T - type of the expected value

Returns:

A MonoProcessor.

cancel

@Deprecated
public void cancel()

Deprecated. the MonoProcessor will cease to implement Subscription in 3.5

Specified by:

cancel in interface Subscription

isCancelled

@Deprecated
public boolean isCancelled()

Deprecated. 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.

Returns:

true if this MonoProcessor is cancelled, false otherwise.

request

@Deprecated
public void request(long n)

Deprecated. the MonoProcessor will cease to implement Subscription in 3.5

Specified by:

request in interface Subscription

Parameters:

n - the request amount

dispose

public void dispose()

Deprecated.

Description copied from interface: Disposable

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Specified by:

dispose in interface Disposable

block

@Nullable
public O block()

Deprecated.

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.

Overrides:

block in class Mono<O>

Returns:

the value of this MonoProcessor

block

@Nullable
public O block(@Nullable
                         Duration timeout)

Deprecated.

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.

Overrides:

block in class Mono<O>

Parameters:

timeout - the timeout value as a Duration

Returns:

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

getError

@Nullable
public Throwable getError()

Deprecated.

Return the produced Throwable error if any or null

Returns:

the produced Throwable error if any or null

isError

public final boolean isError()

Deprecated.

Indicates whether this MonoProcessor has been completed with an error.

Returns:

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

isSuccess

public final boolean isSuccess()

Deprecated.

Indicates whether this MonoProcessor has been successfully completed a value.

Returns:

true if this MonoProcessor is successful, false otherwise.

isTerminated

public boolean isTerminated()

Deprecated.

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

Returns:

true if this MonoProcessor is successful, false otherwise.

isDisposed

public boolean isDisposed()

Deprecated.

Description copied from interface: 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.

Specified by:

isDisposed in interface Disposable

Returns:

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

peek

@Nullable
 @Deprecated
public O peek()

Deprecated. 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.

Returns:

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

Throws:

RuntimeException - if the MonoProcessor was completed with an error

currentContext

public Context currentContext()

Deprecated.

Description copied from interface: CoreSubscriber

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

Specified by:

currentContext in interface CoreSubscriber<O>

Returns:

a resolved context or Context.empty()

scanUnsafe

@Nullable
public Object scanUnsafe(Scannable.Attr key)

Deprecated.

Description copied from interface: 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.

Specified by:

scanUnsafe in interface Scannable

Parameters:

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

Returns:

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

downstreamCount

public long downstreamCount()

Deprecated.

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

Returns:

the number of active Subscriber or -1 if untracked

hasDownstreams

public final boolean hasDownstreams()

Deprecated.

Return true if any Subscriber is actively subscribed

Returns:

true if any Subscriber is actively subscribed

inners

public Stream<? extends Scannable> inners()

Deprecated.

Description copied from interface: Scannable

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

Specified by:

inners in interface Scannable

Returns:

a Stream of referenced inners (flatmap, multicast etc)