reactor.core.publisher

Class MonoOperator<I,O>

java.lang.Object

reactor.core.publisher.Mono<O>

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

Type Parameters:

I - delegate Publisher type

O - produced type

All Implemented Interfaces:

Publisher<O>, Scannable

public abstract class MonoOperator<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.

Nested Class Summary

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

Scannable.Attr<T>

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Object	scanUnsafe(Scannable.Attr key) This method is used internally by components to define their key-value mappings in a single place.

Methods inherited from class reactor.core.publisher.Mono

and, as, block, block, blockOptional, blockOptional, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, compose, concatWith, create, defaultIfEmpty, defer, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterSuccessOrError, doAfterTerminate, doFinally, doOnCancel, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnSuccessOrError, doOnTerminate, elapsed, elapsed, empty, error, expand, expand, expandDeep, expandDeep, 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, name, never, ofType, onAssembly, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onLastAssembly, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, 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, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toProcessor, toString, transform, using, using, when, when, whenDelayError, whenDelayError, zip, zip, zip, zip, zip, zip, zip, zip, 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 reactor.core.Scannable

actuals, from, inners, isScanAvailable, name, operatorName, parents, scan, scanOrDefault, tags

Field Detail

source

protected final Mono<? extends I> source

Constructor Detail

MonoOperator

protected MonoOperator(Mono<? extends I> source)

Build a MonoOperator wrapper around the passed parent Publisher

Parameters:

source - the Publisher to decorate

Method Detail

scanUnsafe

@Nullable
public Object scanUnsafe(Scannable.Attr key)

Description copied from interface: Scannable

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 Scannable.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 Scannable.scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Specified by:

scanUnsafe in interface Scannable

Parameters:

key - a Scannable.Attr to resolve for the component.

Returns:

the value associated to the key for that specific component, or null if none.