类的使用
reactor.core.Scannable.Attr

使用Scannable.Attr的程序包

程序包	说明
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.
reactor.test	Main test components supporting the testing and assertion of publishers.

reactor.core中Scannable.Attr的使用

声明为Scannable.Attr的reactor.core中的字段

限定符和类型	字段和说明
static Scannable.Attr<Scannable>	Scannable.Attr.ACTUAL The direct dependent component downstream reference if any.
static Scannable.Attr<java.lang.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<java.lang.Integer>	Scannable.Attr.BUFFERED A Integer attribute implemented by components with a backlog capacity.
static Scannable.Attr<java.lang.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<java.lang.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<java.lang.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<java.lang.Throwable>	Scannable.Attr.ERROR a Throwable attribute which indicate an error state if the scanned component keeps track of it.
static Scannable.Attr<java.lang.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<java.lang.String>	Scannable.Attr.LIFTER LIFTER attribute exposes name of the lifter function.
static Scannable.Attr<java.lang.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<java.lang.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<java.lang.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<java.util.stream.Stream<Tuple2<java.lang.String,java.lang.String>>>	Scannable.Attr.TAGS A Stream of Tuple2 representing key/value pairs for tagged components.
static Scannable.Attr<java.lang.Boolean>	Scannable.Attr.TERMINATED A Boolean attribute indicating whether or not an upstream component terminated this scanned component. e.g. a post onComplete/onError subscriber.

参数类型为Scannable.Attr的reactor.core中的方法

限定符和类型	方法和说明
default <T> T	Scannable.scan(Scannable.Attr<T> key) 内省方法，扫描返回自身组件 Scannable.Attr 的属性值 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.
java.lang.Object	Scannable.scanUnsafe(Scannable.Attr key) This method is used internally by components to define their key-value mappings in a single place.

reactor.core.publisher中Scannable.Attr的使用

参数类型为Scannable.Attr的reactor.core.publisher中的方法

限定符和类型	方法和说明
java.lang.Object	MonoProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	FluxOperator.scanUnsafe(Scannable.Attr key)
java.lang.Object	FluxProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	EmitterProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	ReplayProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	UnicastProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	MonoOperator.scanUnsafe(Scannable.Attr key)
java.lang.Object	Operators.DeferredSubscription.scanUnsafe(Scannable.Attr key)
java.lang.Object	Operators.MonoSubscriber.scanUnsafe(Scannable.Attr key)

reactor.test中Scannable.Attr的使用

参数类型为Scannable.Attr的reactor.test中的方法

限定符和类型	方法和说明
java.lang.Object	FakeDisposable.scanUnsafe(Scannable.Attr key)