Uses of Package
reactor.core

Packages that use reactor.core

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.
reactor.core.scheduler	Scheduler contract and static registry and factory methods in Schedulers.
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

Classes in reactor.core used by reactor.core

Class and Description
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

Classes in reactor.core used by reactor.core.publisher

Class and Description
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.

Classes in reactor.core used by reactor.core.scheduler

Class and Description
Disposable Indicates that a task or resource can be cancelled/disposed.

Classes in reactor.core used by reactor.test.scheduler

Class and Description
Disposable Indicates that a task or resource can be cancelled/disposed.

Classes in reactor.core used by reactor.test.subscriber

Class and Description
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.

Classes in reactor.core used by reactor.test.util

Class and Description
Disposable Indicates that a task or resource can be cancelled/disposed.