接口的使用
reactor.core.Scannable

使用Scannable的程序包

程序包	说明
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.test.subscriber	Components supporting the creation of test-oriented Subscribers.

reactor.core中Scannable的使用

类型参数类型为Scannable的reactor.core中的字段

限定符和类型	字段和说明
static Scannable.Attr<Scannable>	Scannable.Attr.ACTUAL The direct dependent component downstream reference if any.
static Scannable.Attr<Scannable>	Scannable.Attr.PARENT Parent key exposes the direct upstream relationship of the scanned component.
static Scannable.Attr<Scannable>	Scannable.Attr.RUN_ON A key that links a Scannable to another Scannable it runs on.

返回Scannable的reactor.core中的方法

限定符和类型	方法和说明
static Scannable	Scannable.from(java.lang.Object o) Attempt to cast the Object to a Scannable.

返回变量类型为Scannable的类型的reactor.core中的方法

限定符和类型	方法和说明
default java.util.stream.Stream<? extends Scannable>	Scannable.actuals() Return a Stream navigating the Subscriber chain (downward).
default java.util.stream.Stream<? extends Scannable>	Scannable.inners() Return a Stream of referenced inners (flatmap, multicast etc)
default java.util.stream.Stream<? extends Scannable>	Scannable.parents() Return a Stream navigating the Subscription chain (upward).

reactor.core.publisher中Scannable的使用

reactor.core.publisher中Scannable的子接口

限定符和类型	接口和说明
static interface	Sinks.Empty<T> A base interface for standalone Sinks with complete-or-fail semantics.
static interface	Sinks.Many<T> A base interface for standalone Sinks with Flux semantics.
static interface	Sinks.ManyWithUpstream<T> A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization.
static interface	Sinks.One<T> A base interface for standalone Sinks with Mono semantics.

实现Scannable的reactor.core.publisher中的类

限定符和类型	类和说明
class	DirectProcessor<T> 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
class	EmitterProcessor<T> 已过时。 To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }
class	FluxOperator<I,O> A decorating Flux Publisher that exposes Flux API over an arbitrary Publisher.
class	FluxProcessor<IN,OUT> 已过时。 Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
class	MonoOperator<I,O> A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.
class	MonoProcessor<O> 已过时。 Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
static class	Operators.DeferredSubscription Base class for Subscribers that will receive their Subscriptions at any time, yet they might also need to be cancelled or requested at any time.
class	ReplayProcessor<T> 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
class	UnicastProcessor<T> 已过时。 to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

返回变量类型为Scannable的类型的reactor.core.publisher中的方法

限定符和类型	方法和说明
java.util.stream.Stream<? extends Scannable>	MonoProcessor.inners() 已过时。
java.util.stream.Stream<? extends Scannable>	FluxProcessor.inners() 已过时。
java.util.stream.Stream<? extends Scannable>	EmitterProcessor.inners() 已过时。
java.util.stream.Stream<? extends Scannable>	ReplayProcessor.inners() 已过时。
java.util.stream.Stream<Scannable>	UnicastProcessor.inners() 已过时。
java.util.stream.Stream<? extends Scannable>	DirectProcessor.inners() 已过时。

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

限定符和类型	方法和说明
static <I,O> java.util.function.Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<O>>	Operators.lift(java.util.function.BiFunction<Scannable,? super CoreSubscriber<? super O>,? extends CoreSubscriber<? super I>> lifter) Create a function that can be used to support a custom operator via CoreSubscriber decoration.
static <O> java.util.function.Function<? super org.reactivestreams.Publisher<O>,? extends org.reactivestreams.Publisher<O>>	Operators.lift(java.util.function.Predicate<Scannable> filter, java.util.function.BiFunction<Scannable,? super CoreSubscriber<? super O>,? extends CoreSubscriber<? super O>> lifter) Create a function that can be used to support a custom operator via CoreSubscriber decoration.
static <O> java.util.function.Function<? super org.reactivestreams.Publisher<O>,? extends org.reactivestreams.Publisher<O>>	Operators.lift(java.util.function.Predicate<Scannable> filter, java.util.function.BiFunction<Scannable,? super CoreSubscriber<? super O>,? extends CoreSubscriber<? super O>> lifter) Create a function that can be used to support a custom operator via CoreSubscriber decoration.

reactor.test中Scannable的使用

reactor.test中Scannable的子接口

限定符和类型	接口和说明
static interface	MockUtils.TestScannableConditionalSubscriber<T> An interface that can be used to mock a Scannable Fuseable.ConditionalSubscriber.

实现Scannable的reactor.test中的类

限定符和类型	类和说明
class	FakeDisposable
static class	MockUtils.TestScannableConnectableFlux<T> An abstract class that can be used to mock a Scannable ConnectableFlux.

reactor.test.subscriber中Scannable的使用

reactor.test.subscriber中Scannable的子接口

限定符和类型	接口和说明
interface	ConditionalTestSubscriber<T> Simple interface for a Fuseable.ConditionalSubscriber variant of the TestSubscriber.
interface	TestSubscriber<T> A CoreSubscriber that can be attached to any Publisher to later assert which events occurred at runtime.