Scannable.Attr
Modifier and Type | Field and Description |
---|---|
protected Publisher<? extends I> |
source |
Modifier | Constructor and Description |
---|---|
protected |
MonoSource(Publisher<? extends I> source)
Build a
MonoSource wrapper around the passed parent Publisher |
Modifier and Type | Method and Description |
---|---|
Object |
scan(Scannable.Attr key)
Return an eventual value or null for a given component state
Scannable.Attr |
void |
subscribe(Subscriber<? super O> s)
Default is simply delegating and decorating with
Mono API. |
String |
toString() |
Publisher<? extends I> |
upstream()
Return the direct source of data, Supports reference.
|
static <I> Mono<I> |
wrap(Publisher<? extends I> source)
|
and, and, and, and, as, awaitOnSubscribe, block, block, blockMillis, cache, cancelOn, cast, checkpoint, checkpoint, compose, concatWith, create, defaultIfEmpty, defer, delay, delay, delayElement, delayElement, delayElementMillis, delayElementMillis, delayMillis, delayMillis, delaySubscription, delaySubscription, delaySubscription, delaySubscriptionMillis, delaySubscriptionMillis, dematerialize, doAfterTerminate, doFinally, doOnCancel, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, elapsed, empty, empty, error, filter, filterWhen, first, first, flatMap, 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, mapError, mapError, mapError, materialize, mergeWith, never, ofType, onAssembly, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, 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, switchIfEmpty, then, then, then, then, thenEmpty, thenMany, thenMany, timeout, timeout, timeout, timeout, timeout, timeout, timeoutMillis, timeoutMillis, timeoutMillis, timeoutMillis, timestamp, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
actuals, from, inners, isScanAvailable, parents, scan, scanOrDefault
protected MonoSource(Publisher<? extends I> source)
MonoSource
wrapper around the passed parent Publisher
source
- the Publisher
to decoratepublic void subscribe(Subscriber<? super O> s)
Mono
API. Note this
assumes an identity between input and output types.public final Publisher<? extends I> upstream()
Receiver
public Object scan(Scannable.Attr key)
Scannable
Scannable.Attr
scan
in interface Scannable
key
- an Scannable.Attr
to get the operator state