Package reactor.core

@NullMarked package reactor.core

Core components of the framework supporting extensions to the Reactive Stream programming model.

Related Packages

Package	Description
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.

Class	Description
CorePublisher<T>	A CoreSubscriber aware publisher.
CoreSubscriber<T>	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.
Disposables	A support class that offers factory methods for implementations of the specialized Disposable sub-interfaces (Disposable.Composite, Disposable.Swap).
Exceptions	Global Reactor Core Exception handling and utils to operate on.
Exceptions.SourceException	A Throwable that wraps the actual cause delivered via Subscriber.onError(Throwable) in case of Publishers that themselves emit items of type Publisher.
Fuseable	A micro API for stream fusion, in particular marks producers that support a Fuseable.QueueSubscription.
Fuseable.ConditionalSubscriber<T>	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<T>	Support contract for queue-fusion based optimizations on subscriptions.
Fuseable.ScalarCallable<T>	Marker interface indicating that the target can return a value or null, otherwise fail immediately and thus a viable target for assembly-time optimizations.
Fuseable.SynchronousSubscription<T>	Base class for synchronous sources which have fixed size and can emit their items in a pull fashion, thus avoiding the request-accounting overhead in many cases.
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<T>	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