reactor.core.publisher

Class MonoSource<I,O>

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoSource<I,O>

Type Parameters:

I - delegate Publisher type

O - produced type

All Implemented Interfaces:

Publisher<O>, Scannable

public class MonoSource<I,O>
extends Mono<O>
implements Scannable

A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono, e.g. : flux.as(f -> MonoSource.wrap(f)) .then(d -> Mono.delay(Duration.ofSeconds(1)) .block();

Nested Class Summary

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

Scannable.Attr

Field Summary

Fields

Modifier and Type	Field and Description
protected Publisher<? extends I>	source

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MonoSource(Publisher<? extends I> source) Build a MonoSource wrapper around the passed parent Publisher

Method Summary

Modifier and Type	Method and Description
Object	scan(Scannable.Attr key) Introspect a component's specific state attribute, returning a best effort value or null if the attribute doesn't make sense for that particular component.
void	subscribe(Subscriber<? super O> s) Default is simply delegating and decorating with Mono API.
String	toString()
static <I> Mono<I>	wrap(Publisher<? extends I> source) Unchecked wrap of Publisher as Mono, supporting Fuseable sources

Methods inherited from class reactor.core.publisher.Mono

and, and, and, and, as, awaitOnSubscribe, block, block, cache, cancelOn, cast, checkpoint, checkpoint, compose, concatWith, create, defaultIfEmpty, defer, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, delayUntilOther, dematerialize, doAfterTerminate, doFinally, doOnCancel, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, empty, error, filter, filterWhen, first, first, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromDirect, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, map, materialize, mergeWith, never, ofType, onAssembly, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, then, then, thenEmpty, thenMany, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, transform, untilOther, untilOtherDelayError, using, using, when, when, when, when, when, when, when, when, when, when, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, zip, zip

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.core.Scannable

actuals, from, inners, isScanAvailable, parents, scan, scanOrDefault

Field Detail

source

protected final Publisher<? extends I> source

Constructor Detail

MonoSource

protected MonoSource(Publisher<? extends I> source)

Build a MonoSource wrapper around the passed parent Publisher

Parameters:

source - the Publisher to decorate

Method Detail

wrap

public static <I> Mono<I> wrap(Publisher<? extends I> source)

Unchecked wrap of Publisher as Mono, supporting Fuseable sources

Type Parameters:

I - input upstream type

Parameters:

source - the Publisher to wrap

Returns:

a wrapped Mono

subscribe

public void subscribe(Subscriber<? super O> s)

Default is simply delegating and decorating with Mono API. Note this assumes an identity between input and output types.

Specified by:

subscribe in interface Publisher<O>

toString

public String toString()

Overrides:

toString in class Mono<O>

scan

public Object scan(Scannable.Attr key)

Description copied from interface: Scannable

Introspect a component's specific state attribute, returning a best effort value or null if the attribute doesn't make sense for that particular component.

Specified by:

scan in interface Scannable

Parameters:

key - an Scannable.Attr to get the operator state

Returns:

an eventual value or null