io.rsocket.internal

Class UnicastMonoProcessor<O>

java.lang.Object

reactor.core.publisher.Mono<O>

io.rsocket.internal.UnicastMonoProcessor<O>

All Implemented Interfaces:

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

public class UnicastMonoProcessor<O>
extends Mono<O>
implements org.reactivestreams.Processor<O,O>, CoreSubscriber<O>, Disposable, org.reactivestreams.Subscription, Scannable

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

Method Summary

Modifier and Type	Method and Description
void	cancel()
static <T> UnicastMonoProcessor<T>	create() Create a UnicastMonoProcessor that will eagerly request 1 on onSubscribe(Subscription), cache and emit the eventual result for a single subscriber.
static <T> UnicastMonoProcessor<T>	create(MonoLifecycleHandler<T> lifecycleHandler) Create a UnicastMonoProcessor that will eagerly request 1 on onSubscribe(Subscription), cache and emit the eventual result for a single subscriber.
Context	currentContext()
void	dispose()
Throwable	getError() Return the produced Throwable error if any or null
boolean	hasDownstream() Return true if any Subscriber is actively subscribed
boolean	isCancelled() Indicates whether this UnicastMonoProcessor has been interrupted via cancellation.
boolean	isDisposed()
boolean	isError() Indicates whether this UnicastMonoProcessor has been completed with an error.
boolean	isTerminated()
void	onComplete()
void	onError(Throwable cause)
void	onNext(O value)
void	onSubscribe(org.reactivestreams.Subscription subscription)
O	peek() Returns the value that completed this UnicastMonoProcessor.
void	request(long n)
Object	scanUnsafe(Scannable.Attr key)
void	subscribe(CoreSubscriber<? super O> actual)

Methods inherited from class reactor.core.publisher.Mono

and, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, compose, concatWith, create, defaultIfEmpty, defer, deferWithContext, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterSuccessOrError, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnSuccessOrError, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, materialize, mergeWith, metrics, name, never, ofType, onAssembly, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onLastAssembly, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, retryBackoff, retryBackoff, retryBackoff, retryBackoff, retryBackoff, retryWhen, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, single, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscriberContext, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, then, then, thenEmpty, thenMany, thenReturn, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toProcessor, toString, transform, transformDeferred, using, using, usingWhen, usingWhen, 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.Scannable

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

Method Detail

create

public static <T> UnicastMonoProcessor<T> create()

Create a UnicastMonoProcessor that will eagerly request 1 on onSubscribe(Subscription), cache and emit the eventual result for a single subscriber.

Type Parameters:

T - type of the expected value

Returns:

A UnicastMonoProcessor.

create

public static <T> UnicastMonoProcessor<T> create(MonoLifecycleHandler<T> lifecycleHandler)

Create a UnicastMonoProcessor that will eagerly request 1 on onSubscribe(Subscription), cache and emit the eventual result for a single subscriber.

Type Parameters:

T - type of the expected value

Parameters:

lifecycleHandler - lifecycle handler

Returns:

A UnicastMonoProcessor.

currentContext

@NonNull
public Context currentContext()

Specified by:

currentContext in interface CoreSubscriber<O>

onSubscribe

public final void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<O>

Specified by:

onSubscribe in interface CoreSubscriber<O>

onComplete

public final void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<O>

onError

public final void onError(Throwable cause)

Specified by:

onError in interface org.reactivestreams.Subscriber<O>

onNext

public final void onNext(@Nullable
                         O value)

Specified by:

onNext in interface org.reactivestreams.Subscriber<O>

subscribe

public void subscribe(CoreSubscriber<? super O> actual)

Specified by:

subscribe in interface CorePublisher<O>

Specified by:

subscribe in class Mono<O>

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public final void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

dispose

public void dispose()

Specified by:

dispose in interface Disposable

peek

@Nullable
public O peek()

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

Returns:

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

Throws:

RuntimeException - if the UnicastMonoProcessor was completed with an error

getError

@Nullable
public final Throwable getError()

Return the produced Throwable error if any or null

Returns:

the produced Throwable error if any or null

isError

public final boolean isError()

Indicates whether this UnicastMonoProcessor has been completed with an error.

Returns:

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

isCancelled

public boolean isCancelled()

Indicates whether this UnicastMonoProcessor has been interrupted via cancellation.

Returns:

true if this UnicastMonoProcessor is cancelled, false otherwise.

isTerminated

public final boolean isTerminated()

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface Disposable

scanUnsafe

@Nullable
public Object scanUnsafe(Scannable.Attr key)

Specified by:

scanUnsafe in interface Scannable

hasDownstream

public final boolean hasDownstream()

Return true if any Subscriber is actively subscribed

Returns:

true if any Subscriber is actively subscribed