Reactor Core 3.6.0 · reactor.core.publisher.MonoOperator

A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.

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

Constructor Summary

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

Method Summary

Modifier and Type	Method and Description
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.

Inherited from reactor.core.publisher.Mono:: and as block block blockOptional blockOptional cache cache cache cache cache cacheInvalidateIf cacheInvalidateWhen cacheInvalidateWhen cancelOn cast checkpoint checkpoint checkpoint concatWith contextCapture contextWrite contextWrite create defaultIfEmpty defer deferContextual delay delay delayElement delayElement delaySubscription delaySubscription delaySubscription delayUntil dematerialize doAfterTerminate doFinally doFirst doOnCancel doOnDiscard doOnEach doOnError doOnError doOnError doOnNext doOnRequest doOnSignal doOnSubscribe doOnSuccess doOnTerminalSignal doOnTerminate elapsed elapsed empty empty equalsBiPredicate error error expand expand expandDeep expandDeep filter filterWhen first first firstWithSignal firstWithSignal firstWithValue firstWithValue flatMap flatMapIterable flatMapMany flatMapMany flux from fromCallable fromCompletionStage fromCompletionStage fromDirect fromFuture fromFuture fromFuture fromFuture fromRunnable fromSupplier handle hasElement hide ignoreElement ignoreElements just justOrEmpty justOrEmpty log log log log log log map mapNotNull materialize mergeWith metrics name never ofType onAssembly onErrorComplete onErrorComplete onErrorComplete onErrorContinue onErrorContinue onErrorContinue onErrorMap onErrorMap onErrorMap onErrorResume onErrorResume onErrorResume onErrorReturn onErrorReturn onErrorReturn onErrorStop onTerminateDetach or publish publishOn repeat repeat repeat repeat repeatWhen repeatWhenEmpty repeatWhenEmpty retry retry retryWhen sequenceEqual sequenceEqual sequenceEqual share single singleOptional subscribe subscribe subscribe subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeWith switchIfEmpty tag take take takeUntilOther tap tap tap then then thenEmpty thenMany thenReturn timed timed timeout timeout timeout timeout timeout timeout timestamp timestamp toFuture toString transform transformDeferred transformDeferredContextual using using usingWhen usingWhen when when whenDelayError whenDelayError wrap zip zip zip zip zip zip zip zip zip zip zipDelayError zipDelayError zipDelayError zipDelayError zipDelayError zipDelayError zipDelayError zipDelayError zipDelayError zipWhen zipWhen zipWith zipWith

Field Detail

source	back to summary
protected final Mono<? extends I> source

Constructor Detail

MonoOperator back to summary

MonoOperator	back to summary
protected MonoOperator(Mono<? extends I> source) Build a `MonoOperator` wrapper around the passed parent `Publisher` Parameters source:Mono<? extends I> the `Publisher` to decorate

protected MonoOperator(Mono<? extends I> source)

Build a MonoOperator wrapper around the passed parent Publisher

Parameters

source:Mono<? extends I>: the Publisher to decorate

Method Detail

scanUnsafe back to summary

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

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

Implements reactor.core.Scannable.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

public abstract Class MonoOperator<I, O>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail