Uses of Class
reactor.core.Scannable.Attr

Packages that use Scannable.Attr

Package	Description
reactor.core	Core components of the framework supporting extensions to the Reactive Stream programming model.
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

Uses of Scannable.Attr in reactor.core

Fields in reactor.core declared as Scannable.Attr

Modifier and Type	Field and Description
static Scannable.Attr<Scannable>	Scannable.Attr.ACTUAL The direct dependent component downstream reference if any.
static Scannable.Attr<Boolean>	Scannable.Attr.ACTUAL_METADATA Indicate that for some purposes a Scannable should be used as additional source of information about a contiguous Scannable in the chain.
static Scannable.Attr<Integer>	Scannable.Attr.BUFFERED A Integer attribute implemented by components with a backlog capacity.
static Scannable.Attr<Boolean>	Scannable.Attr.CANCELLED A Boolean attribute indicating whether or not a downstream component has interrupted consuming this scanned component, e.g., a cancelled subscription.
static Scannable.Attr<Integer>	Scannable.Attr.CAPACITY Return an an Integer capacity when no PREFETCH is defined or when an arbitrary maximum limit is applied to the backlog capacity of the scanned component.
static Scannable.Attr<Boolean>	Scannable.Attr.DELAY_ERROR Delay_Error exposes a Boolean whether the scanned component actively supports error delaying if it manages a backlog instead of fast error-passing which might drop pending backlog.
static Scannable.Attr<Throwable>	Scannable.Attr.ERROR a Throwable attribute which indicate an error state if the scanned component keeps track of it.
static Scannable.Attr<Long>	Scannable.Attr.LARGE_BUFFERED Similar to BUFFERED, but reserved for operators that can hold a backlog of items that can grow beyond Integer.MAX_VALUE.
static Scannable.Attr<String>	Scannable.Attr.LIFTER LIFTER attribute exposes name of the lifter function.
static Scannable.Attr<String>	Scannable.Attr.NAME An arbitrary name given to the operator component.
static Scannable.Attr<Scannable>	Scannable.Attr.PARENT Parent key exposes the direct upstream relationship of the scanned component.
static Scannable.Attr<Integer>	Scannable.Attr.PREFETCH Prefetch is an Integer attribute defining the rate of processing in a component which has capacity to request and hold a backlog of data.
static Scannable.Attr<Long>	Scannable.Attr.REQUESTED_FROM_DOWNSTREAM A Long attribute exposing the current pending demand of a downstream component.
static Scannable.Attr<Scannable>	Scannable.Attr.RUN_ON A key that links a Scannable to another Scannable it runs on.
static Scannable.Attr<Scannable.Attr.RunStyle>	Scannable.Attr.RUN_STYLE An Scannable.Attr.RunStyle enum attribute indicating whether or not an operator continues to operate on the same thread.
static Scannable.Attr<Stream<Tuple2<String,String>>>	Scannable.Attr.TAGS A Stream of Tuple2 representing key/value pairs for tagged components.
static Scannable.Attr<Boolean>	Scannable.Attr.TERMINATED A Boolean attribute indicating whether or not an upstream component terminated this scanned component.

Methods in reactor.core with parameters of type Scannable.Attr

Modifier and Type	Method and Description
default <T> T	Scannable.scan(Scannable.Attr<T> key) Introspect a component's specific state attribute, returning an associated value specific to that component, or the default value associated with the key, or null if the attribute doesn't make sense for that particular component and has no sensible default.
default <T> T	Scannable.scanOrDefault(Scannable.Attr<T> key, T defaultValue) Introspect a component's specific state attribute.
Object	Scannable.scanUnsafe(Scannable.Attr key) This method is used internally by components to define their key-value mappings in a single place.

Uses of Scannable.Attr in reactor.core.publisher

Methods in reactor.core.publisher with parameters of type Scannable.Attr

Modifier and Type	Method and Description
Object	ReplayProcessor.scanUnsafe(Scannable.Attr key) Deprecated.
Object	Operators.DeferredSubscription.scanUnsafe(Scannable.Attr key)
Object	Operators.MonoSubscriber.scanUnsafe(Scannable.Attr key)
Object	UnicastProcessor.scanUnsafe(Scannable.Attr key) Deprecated.
Object	EmitterProcessor.scanUnsafe(Scannable.Attr key) Deprecated.
Object	FluxProcessor.scanUnsafe(Scannable.Attr key) Deprecated.
Object	FluxOperator.scanUnsafe(Scannable.Attr key)
Object	MonoProcessor.scanUnsafe(Scannable.Attr key) Deprecated.
Object	MonoOperator.scanUnsafe(Scannable.Attr key)