Overrides reactor.core.publisher.MonoProcessor.block.

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

Returns:O

the value of this NextProcessor

Annotations

@Override

@Nullable

Overrides reactor.core.publisher.MonoProcessor.block.

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

Parameters

timeout:Duration

the timeout value as a Duration

Returns:O

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

Annotations

@Override

@Nullable

Overrides reactor.core.publisher.MonoProcessor.cancel.

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

@SuppressWarnings:deprecation

Overrides reactor.core.publisher.MonoProcessor.currentContext.

Overrides default reactor.core.CoreSubscriber.currentContext.

Doc from reactor.core.CoreSubscriber.currentContext.

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

Returns:Context

a resolved context or Context#empty()

Annotations

@Override

Overrides reactor.core.publisher.MonoProcessor.dispose.

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations

@Override

@SuppressWarnings:unchecked

Overrides reactor.core.publisher.MonoProcessor.downstreamCount.

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

Returns:long

the number of active Subscriber or -1 if untracked

Annotations

@Override

Overrides reactor.core.publisher.MonoProcessor.getError.

Return the produced Throwable error if any or null

Returns:Throwable

the produced Throwable error if any or null

Annotations

@Nullable

@Override

Overrides reactor.core.publisher.MonoProcessor.inners.

Overrides default reactor.core.Scannable.inners.

Doc from reactor.core.Scannable.inners.

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

Returns:Stream<? extends Scannable>

a Stream of referenced inners (flatmap, multicast etc)

Annotations

@Override

Overrides reactor.core.publisher.MonoProcessor.isCancelled.

Doc from reactor.core.publisher.MonoProcessor.isCancelled.

Indicates whether this MonoProcessor has been interrupted via cancellation.

Returns:boolean

true if this MonoProcessor is cancelled, false otherwise.

Annotations

@Override

@SuppressWarnings:deprecation

Overrides reactor.core.publisher.MonoProcessor.isDisposed.

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

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.

Returns:boolean

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

Annotations

@Override

Overrides reactor.core.publisher.MonoProcessor.isTerminated.

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

Returns:boolean

true if this NextProcessor is successful, false otherwise.

Annotations

@Override

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters

cause:Throwable

the throwable signaled

Annotations

@Override

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

value:O

the element signaled

Annotations

@Override

Implements reactor.core.CoreSubscriber.onSubscribe, org.reactivestreams.Subscriber.onSubscribe.

Doc from reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by 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 reactor.util.Logger. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

subscription:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

Overrides reactor.core.publisher.MonoProcessor.peek.

For testing purpose.

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

Returns:O

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

Annotations

@Nullable

@Override

Exceptions

RuntimeException:

if the NextProcessor was completed with an error

Overrides reactor.core.publisher.MonoProcessor.scanUnsafe.

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

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 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 scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters

key:Scannable.Attr<T>

a Attr to resolve for the component.

Returns:Object

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

Annotations

@Nullable

@Override

Implements abstract reactor.core.publisher.Mono.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Mono.subscribe.

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.

Parameters

actual:CoreSubscriber<? super O>

the Subscriber interested into the published sequence

Annotations

@Override