Top Description Fields Methods
reactor.core.publisher

pack-priv Interface SourceProducer<O>

extends Scannable, Publisher<O>
Known Direct Implementers
reactor.core.publisher.FluxUsing, reactor.core.publisher.FluxUsingWhen, reactor.core.publisher.FluxZip, reactor.core.publisher.MonoDefer, reactor.core.publisher.MonoDeferContextual, reactor.core.publisher.MonoDelay, reactor.core.publisher.MonoEmpty, reactor.core.publisher.MonoError, reactor.core.publisher.MonoErrorSupplied, reactor.core.publisher.MonoFirstWithSignal, reactor.core.publisher.MonoFirstWithValue, reactor.core.publisher.MonoUsing, reactor.core.publisher.MonoUsingWhen, reactor.core.publisher.MonoWhen, reactor.core.publisher.MonoZip, reactor.core.publisher.ParallelArraySource, reactor.core.publisher.FluxNever, reactor.core.publisher.FluxRange, reactor.core.publisher.MonoSequenceEqual, reactor.core.publisher.FluxCreate, reactor.core.publisher.FluxDefer, reactor.core.publisher.FluxDeferContextual, reactor.core.publisher.FluxEmpty, reactor.core.publisher.FluxError, reactor.core.publisher.FluxErrorOnRequest, reactor.core.publisher.FluxErrorSupplied, reactor.core.publisher.FluxFirstWithSignal, reactor.core.publisher.FluxFirstWithValue, reactor.core.publisher.MonoNever, reactor.core.publisher.MonoRunnable, reactor.core.publisher.MonoCallable, reactor.core.publisher.MonoCreate, reactor.core.publisher.FluxArray, reactor.core.publisher.FluxCallable, reactor.core.publisher.FluxCombineLatest, reactor.core.publisher.FluxConcatArray, reactor.core.publisher.FluxConcatIterable, reactor.core.publisher.FluxGenerate, reactor.core.publisher.FluxInterval, reactor.core.publisher.FluxIterable, reactor.core.publisher.FluxJust, reactor.core.publisher.FluxMerge, reactor.core.publisher.FluxMergeComparing, reactor.core.publisher.MonoJust, reactor.core.publisher.FluxSource, reactor.core.publisher.FluxSourceFuseable, reactor.core.publisher.FluxStream, reactor.core.publisher.MonoSingleCallable, reactor.core.publisher.MonoSingleOptionalCallable, reactor.core.publisher.MonoSource, reactor.core.publisher.MonoSupplier
Type Parameters
<O>
output operator produced type
Imports
org.reactivestreams.Publisher, reactor.core.Scannable, reactor.util.annotation.Nullable
SourceProducer is a Publisher that is Scannable for the purpose of being tied back to a chain of operators. By itself it doesn't allow walking the hierarchy of operators, as they can only be tied from downstream to upstream by referencing their sources.
Author
Simon Baslé

Field Summary

Inherited from reactor.core.Scannable:
OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Method Summary

Modifier and TypeMethod and Description
public default 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.
public default String
stepName()

Overrides default reactor.core.Scannable.stepName.

Return a meaningful String representation of this Scannable in its chain of parents() and actuals().
Inherited from org.reactivestreams.Publisher:
subscribe
Inherited from reactor.core.Scannable:
actualsfrominnersisScanAvailablenameparentsscanscanOrDefaultstepstagstagsDeduplicated

Method Detail

scanUnsafeback to summary
public default 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
stepNameback to summary
public default String stepName()

Overrides default reactor.core.Scannable.stepName.

Doc from reactor.core.Scannable.stepName.

Return a meaningful String representation of this Scannable in its chain of parents() and actuals().

Annotations
@Override