程序包的使用
reactor.core

使用reactor.core的程序包

程序包	说明
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.core.publisher.scenarios
reactor.core.scheduler	Scheduler contract and static registry and factory methods in Schedulers.
reactor.test	Main test components supporting the testing and assertion of publishers.
reactor.test.scheduler	Components supporting the creation of test-oriented Schedulers.
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.
reactor.test.util

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

类和说明
CoreSubscriber A Context aware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original Subscriber from Reactive Streams.
Disposable Indicates that a task or resource can be cancelled/disposed.
Disposable.Composite A container of Disposable that is itself Disposable.
Disposable.Swap A Disposable container that allows updating/replacing its inner Disposable atomically and with respect of disposing the container itself.
Fuseable.QueueSubscription Support contract for queue-fusion based optimizations on subscriptions.
Scannable A Scannable component exposes state in a non strictly memory consistent way and results should be understood as best-effort hint of the underlying state.
Scannable.Attr Base class for Scannable attributes, which all can define a meaningful default.
Scannable.Attr.RunStyle An Enum enumerating the different styles an operator can run : their Enum.ordinal() reflects the level of confidence in their running mode

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

类和说明
CorePublisher A CoreSubscriber aware publisher.
CoreSubscriber A Context aware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original Subscriber from Reactive Streams.
Disposable Indicates that a task or resource can be cancelled/disposed.
Fuseable A micro API for stream fusion, in particular marks producers that support a Fuseable.QueueSubscription.
Fuseable.ConditionalSubscriber A subscriber variant that can immediately tell if it consumed the value or not, directly allowing a new value to be sent if it didn't.
Fuseable.QueueSubscription Support contract for queue-fusion based optimizations on subscriptions.
Scannable A Scannable component exposes state in a non strictly memory consistent way and results should be understood as best-effort hint of the underlying state.
Scannable.Attr Base class for Scannable attributes, which all can define a meaningful default.

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

类和说明
TestLoggerExtension.Capture Set up a default TestLoggerExtension, unless @TestLoggerExtension.Redirect annotation is also present.

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

类和说明
Disposable Indicates that a task or resource can be cancelled/disposed.

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

类和说明
CorePublisher A CoreSubscriber aware publisher.
CoreSubscriber A Context aware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original Subscriber from Reactive Streams.
Disposable Indicates that a task or resource can be cancelled/disposed.
Fuseable.ConditionalSubscriber A subscriber variant that can immediately tell if it consumed the value or not, directly allowing a new value to be sent if it didn't.
Scannable A Scannable component exposes state in a non strictly memory consistent way and results should be understood as best-effort hint of the underlying state.
Scannable.Attr Base class for Scannable attributes, which all can define a meaningful default.

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

类和说明
Disposable Indicates that a task or resource can be cancelled/disposed.

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

类和说明
CoreSubscriber A Context aware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original Subscriber from Reactive Streams.
Fuseable.ConditionalSubscriber A subscriber variant that can immediately tell if it consumed the value or not, directly allowing a new value to be sent if it didn't.
Scannable A Scannable component exposes state in a non strictly memory consistent way and results should be understood as best-effort hint of the underlying state.

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

类和说明
Disposable Indicates that a task or resource can be cancelled/disposed.