Implements reactor.core.publisher.InnerProducer.actual.

Annotations

@Override

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

Overrides default reactor.core.publisher.MonoSink.contextView.

Doc from reactor.core.publisher.MonoSink.contextView.

Return the current subscriber's context as a ContextView for inspection.

Context can be enriched downstream via Mono#contextWrite(Function) operator or directly by a child subscriber overriding CoreSubscriber#currentContext().

Returns:ContextView

the current subscriber ContextView.

Annotations

@Override

Implements reactor.core.publisher.MonoSink.currentContext.

Doc from reactor.core.publisher.MonoSink.currentContext.

Return the current subscriber Context.

Context can be enriched via Mono#contextWrite(Function) operator or directly by a child subscriber overriding CoreSubscriber#currentContext()

Annotations

@Override

@Deprecated

Implements reactor.core.publisher.MonoSink.error.

Doc from reactor.core.publisher.MonoSink.error.

Terminate with the given exception

Calling this method multiple times or after the other terminating methods is an unsupported operation. It will discard the exception through the Hooks#onErrorDropped(Consumer) hook. This is to avoid complete and silent swallowing of the exception.

Parameters

e:Throwable

the exception to complete with

Annotations

@Override

Implements reactor.core.publisher.MonoSink.onCancel.

Doc from reactor.core.publisher.MonoSink.onCancel.

Attach a Disposable as a callback for when this MonoSink is cancelled. At most one callback can be registered, and subsequent calls to this method will result in the immediate disposal of the extraneous Disposable.

The callback is only relevant when the downstream Subscription is cancelled.

Parameters

d:Disposable

the Disposable to use as a callback

Returns:MonoSink<T>

the MonoSink with a cancellation callback

Annotations

@Override

Implements reactor.core.publisher.MonoSink.onDispose.

Doc from reactor.core.publisher.MonoSink.onDispose.

Attach a Disposable as a callback for when this MonoSink is effectively disposed, that is it cannot be used anymore. This includes both having played terminal signals (onComplete, onError) and having been cancelled (see onCancel(Disposable)). At most one callback can be registered, and subsequent calls to this method will result in the immediate disposal of the extraneous Disposable.

Note that the "dispose" term is used from the perspective of the sink. Not to be confused with Mono#subscribe()'s Disposable#dispose() method, which maps to disposing the Subscription (effectively, a Subscription#cancel() signal).

Parameters

d:Disposable

the Disposable to use as a callback

Returns:MonoSink<T>

the MonoSink with a callback invoked on any terminal signal or on cancellation

Annotations

@Override

Implements reactor.core.publisher.MonoSink.onRequest.

Doc from reactor.core.publisher.MonoSink.onRequest.

Attaches a LongConsumer to this MonoSink that will be notified of any request to this sink.

Parameters

consumer:LongConsumer

the consumer to invoke on request

Returns:MonoSink<T>

MonoSink with a consumer that is notified of requests

Annotations

@Override

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long

the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

Overrides default reactor.core.publisher.InnerProducer.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

@Override

@Nullable

Implements reactor.core.publisher.MonoSink.success.

Doc from reactor.core.publisher.MonoSink.success.

Complete without any value.

Calling this method multiple times or after the other terminating methods has no effect.

Annotations

@Override

Implements reactor.core.publisher.MonoSink.success.

Doc from reactor.core.publisher.MonoSink.success.

Complete this Mono with the given value.

Calling this method multiple times or after the other terminating methods has no effect (the value is dropped). Calling this method with a null value will be silently accepted as a call to success() by standard implementations.

Parameters

value:T

the value to complete with

Annotations

@Override

Overrides java.util.concurrent.atomic.AtomicBoolean.toString.

Doc from java.util.concurrent.atomic.AtomicBoolean.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations

@Override