程序包的使用
reactor.core.publisher

使用reactor.core.publisher的程序包

程序包	说明
reactor.adapter	Adapt Publisher to Java 9+ Flow.Publisher.
reactor.core.observability
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.core.scheduler	Scheduler contract and static registry and factory methods in Schedulers.
reactor.guide
reactor.test	Main test components supporting the testing and assertion of publishers.
reactor.test.publisher	Components supporting the creation of test-oriented Publishers.
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.
reactor.util.retry

reactor.adapter使用的reactor.core.publisher中的类

类和说明
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).

reactor.core.observability使用的reactor.core.publisher中的类

类和说明
SignalType Reactive Stream signal types

reactor.core.publisher使用的reactor.core.publisher中的类

类和说明
AbstractFluxConcatMapTest
BufferOverflowStrategy Strategies to deal with overflow of a buffer during backpressure buffering.
ConnectableFlux The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.
DirectProcessor 已过时。 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.
EmitterProcessor 已过时。 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); }
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
FluxConcatMapNoPrefetchStressTest
FluxProcessor 已过时。 Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
FluxSink Wrapper API around a downstream Subscriber for emitting any number of next signals followed by zero or one onError/onComplete.
FluxSink.OverflowStrategy Enumeration for backpressure handling.
FluxSwitchMapStressTest
FluxSwitchOnFirstConditionalStressTest
FluxSwitchOnFirstStressTest
FluxSwitchOnFirstStressTest.LLLLLLLLL_Result
GroupedFlux Represents a sequence of events which has an associated key.
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).
MonoProcessor 已过时。 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
MonoSink Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).
ParallelFlux A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').
ReplayProcessor 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
Signal A domain representation of a Reactive Stream signal.
SignalType Reactive Stream signal types
SinkEmptySerializedStressTest
SinkManySerializedStressTest
SinkOneSerializedStressTest
SinkOneStressTest
Sinks.EmitFailureHandler A handler supporting the emit API (eg.
Sinks.EmitResult Represents the immediate result of an emit attempt (eg. in Sinks.Many.tryEmitNext(Object).
Sinks.Empty A base interface for standalone Sinks with complete-or-fail semantics.
Sinks.Many A base interface for standalone Sinks with Flux semantics.
Sinks.ManySpec Provides Sinks.Many specs for sinks which can emit multiple elements
Sinks.ManyWithUpstream A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization.
Sinks.ManyWithUpstreamUnsafeSpec Instead of unsafe flavors of Sinks.Many, this spec provides Sinks.ManyWithUpstream implementations.
Sinks.MulticastReplaySpec Provides multicast with history/replay capacity : 1 sink, N Subscriber
Sinks.MulticastSpec Provides multicast : 1 sink, N Subscriber
Sinks.One A base interface for standalone Sinks with Mono semantics.
Sinks.RootSpec Provides a choice of Sinks.One/Sinks.Empty factories and further specs for Sinks.Many.
Sinks.UnicastSpec Provides unicast: 1 sink, 1 Subscriber
StressSubscriber
SynchronousSink Interface to produce synchronously "one signal" to an underlying Subscriber.
Timed
UnicastProcessor 已过时。 to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

reactor.core.scheduler使用的reactor.core.publisher中的类

类和说明
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).

reactor.guide使用的reactor.core.publisher中的类

类和说明
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).

reactor.test使用的reactor.core.publisher中的类

类和说明
ConnectableFlux The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Signal A domain representation of a Reactive Stream signal.

reactor.test.publisher使用的reactor.core.publisher中的类

类和说明
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).
ParallelFlux A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').

reactor.test.subscriber使用的reactor.core.publisher中的类

类和说明
Signal A domain representation of a Reactive Stream signal.

reactor.util.retry使用的reactor.core.publisher中的类

类和说明
Flux A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Mono A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).