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:

org.reactivestreams.Publisher<O>, Receiver

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

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 -> new MonoSource<>(f)) .then(d -> Mono.delay(1)) .get();

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MonoSource(org.reactivestreams.Publisher<? extends I> source)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super O> s) Default is delegating and decorating with Mono API
java.lang.String	toString()
org.reactivestreams.Publisher<? extends I>	upstream() Return the direct source of data, Supports reference.
static <I> Mono<I>	wrap(org.reactivestreams.Publisher<? extends I> source) Unchecked wrap of Publisher as Mono, supporting Fuseable sources

Methods inherited from class reactor.core.publisher.Mono

and, and, as, awaitOnSubscribe, block, block, blockMillis, cache, cancelOn, cast, compose, concatWith, create, defaultIfEmpty, defer, delay, delayMillis, delayMillis, delaySubscription, delaySubscription, delaySubscriptionMillis, delaySubscriptionMillis, dematerialize, doAfterTerminate, doOnCancel, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, empty, error, filter, first, first, flatMap, flatMap, flatMapIterable, flux, from, fromCallable, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, map, mapError, mapError, mapError, materialize, mergeWith, never, ofType, onAssembly, onTerminateDetach, or, otherwise, otherwise, otherwise, otherwiseIfEmpty, otherwiseReturn, otherwiseReturn, otherwiseReturn, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, then, then, then, then, thenMany, thenMany, timeout, timeout, timeout, timeout, timeoutMillis, timeoutMillis, timeoutMillis, timeoutMillis, timestamp, timestamp, toFuture, transform, using, using, when, when, when, when, when, when, when, when, when, when, 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

Field Detail

source

protected final org.reactivestreams.Publisher<? extends I> source

Constructor Detail

MonoSource

protected MonoSource(org.reactivestreams.Publisher<? extends I> source)

Method Detail

wrap

public static <I> Mono<I> wrap(org.reactivestreams.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(org.reactivestreams.Subscriber<? super O> s)

Default is delegating and decorating with Mono API

Specified by:

subscribe in interface org.reactivestreams.Publisher<O>

toString

public java.lang.String toString()

Overrides:

toString in class Mono<O>

upstream

public final org.reactivestreams.Publisher<? extends I> upstream()

Description copied from interface: Receiver

Return the direct source of data, Supports reference.

Specified by:

upstream in interface Receiver

Returns:

the direct source of data, Supports reference.