Modifier and Type	Class and Description
pack-priv static class	MonoRunnable.MonoRunnableEagerSubscription

Modifier and Type	Field and Description
pack-priv final Runnable	run

Access	Constructor and Description
pack-priv	MonoRunnable(Runnable run)

Modifier and Type	Method and Description
public T	block(Duration maximum time period to wait for before raising a `RuntimeException` m) Overrides reactor.core.publisher.Mono.block. Subscribe to this `Mono` and block until a next signal is received or a timeout expires.
public T	block() Overrides reactor.core.publisher.Mono.block. Subscribe to this `Mono` and block indefinitely until a next signal is received.
public Void	call() Implements java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Overrides default reactor.core.publisher.SourceProducer.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public void	subscribe(CoreSubscriber<? super T> the `Subscriber` interested into the published sequence actual) Implements abstract reactor.core.publisher.Mono.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.

run	back to summary
pack-priv final Runnable run

MonoRunnable	back to summary
pack-priv MonoRunnable(Runnable run)

Method Detail

block back to summary

block	back to summary
public T block(Duration m) Overrides reactor.core.publisher.Mono.block. Doc from reactor.core.publisher.Mono.block. Subscribe to this `Mono` and block until a next signal is received or a timeout expires. Returns that value, or null if the Mono completes empty. In case the Mono errors, the original exception is thrown (wrapped in a `RuntimeException` if it was a checked exception). If the provided timeout expires, a `RuntimeException` is thrown. Note that each block() will trigger a new subscription: in other words, the result might miss signal from hot publishers. Parameters m:Duration maximum time period to wait for before raising a `RuntimeException` Returns:T T the result Annotations @Override @Nullable

public T block(Duration m)

Overrides reactor.core.publisher.Mono.block.

Doc from reactor.core.publisher.Mono.block.

Subscribe to this Mono and block until a next signal is received or a timeout expires. Returns that value, or null if the Mono completes empty. In case the Mono errors, the original exception is thrown (wrapped in a RuntimeException if it was a checked exception). If the provided timeout expires, a RuntimeException is thrown.

Note that each block() will trigger a new subscription: in other words, the result might miss signal from hot publishers.

Parameters

m:Duration: maximum time period to wait for before raising a RuntimeException

Returns:T

T the result

Annotations

@Override
@Nullable

block back to summary

block	back to summary
public T block() Overrides reactor.core.publisher.Mono.block. Doc from reactor.core.publisher.Mono.block. Subscribe to this `Mono` and block indefinitely until a next signal is received. Returns that value, or null if the Mono completes empty. In case the Mono errors, the original exception is thrown (wrapped in a `RuntimeException` if it was a checked exception). Note that each block() will trigger a new subscription: in other words, the result might miss signal from hot publishers. Returns:T T the result Annotations @Override @Nullable

public T block()

Overrides reactor.core.publisher.Mono.block.

Doc from reactor.core.publisher.Mono.block.

Subscribe to this Mono and block indefinitely until a next signal is received. Returns that value, or null if the Mono completes empty. In case the Mono errors, the original exception is thrown (wrapped in a RuntimeException if it was a checked exception).

Note that each block() will trigger a new subscription: in other words, the result might miss signal from hot publishers.

Returns:T

T the result

Annotations

@Override
@Nullable

call	back to summary
public Void call() throws Exception Implements java.util.concurrent.Callable.call. Doc from java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so. Returns:Void computed result Annotations @Override @Nullable Exceptions Exception: if unable to compute a result

call

back to summary

public Void call() throws Exception

Implements java.util.concurrent.Callable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:Void

computed result

Annotations

@Override
@Nullable

Exceptions

Exception:: if unable to compute a result

scanUnsafe back to summary

scanUnsafe	back to summary
public Object scanUnsafe(Scannable.Attr<T> key) Overrides default reactor.core.publisher.SourceProducer.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

public Object scanUnsafe(Scannable.Attr<T> key)

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

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super T> actual) 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 T> the `Subscriber` interested into the published sequence Annotations @Override

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

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 T>: the Subscriber interested into the published sequence

Annotations

@Override

reactor.core.publisher back to summary

pack-priv final Class MonoRunnable.MonoRunnableEagerSubscription

Class Inheritance

extends AtomicBoolean
implements Subscription

java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
reactor.core.publisher.MonoRunnable.MonoRunnableEagerSubscription

All Implemented Interfaces

org.reactivestreams.Subscription

Constructor Summary

Access	Constructor and Description
pack-priv	MonoRunnableEagerSubscription()

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
public boolean	isCancelled()
public void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.

Constructor Detail

MonoRunnableEagerSubscription	back to summary
pack-priv MonoRunnableEagerSubscription()

Method Detail

cancel back to summary

cancel	back to summary
public void 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

public void 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

isCancelled	back to summary
public boolean isCancelled()

request back to summary

request	back to summary
public void request(long n) 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

public void request(long n)

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

pack-priv final Class MonoRunnable<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class MonoRunnable.MonoRunnableEagerSubscription

Constructor Summary

Method Summary

Constructor Detail

Method Detail