@NonNullApi

Package reactor.core

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

See: Description

Interface Summary

Interface	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.
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.

Class Summary

Class	Description
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.
Scannable.Attr<T>	Base class for Scannable attributes, which all can define a meaningful default.

Enum Summary

Enum	Description
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

Exception Summary

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

Package reactor.core Description

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