Package reactor.core
@NullMarked
package reactor.core
Core components of the framework supporting extensions to the Reactive Stream
programming model.
-
ClassDescriptionA
CoreSubscriberaware publisher.AContextaware subscriber which has relaxed rules for §1.3 and §3.9 compared to the originalSubscriberfrom Reactive Streams.Indicates that a task or resource can be cancelled/disposed.A container ofDisposablethat is itselfDisposable.ADisposablecontainer that allows updating/replacing its inner Disposable atomically and with respect of disposing the container itself.A support class that offers factory methods for implementations of the specializedDisposablesub-interfaces (Disposable.Composite,Disposable.Swap).Global Reactor Core Exception handling and utils to operate on.AThrowablethat wraps the actualcausedelivered viaSubscriber.onError(Throwable)in case ofPublishers that themselves emit items of typePublisher.A micro API for stream fusion, in particular marks producers that support aFuseable.QueueSubscription.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.Support contract for queue-fusion based optimizations on subscriptions.Marker interface indicating that the target can return a value or null, otherwise fail immediately and thus a viable target for assembly-time optimizations.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.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.Base class forScannableattributes, which all can define a meaningful default.AnEnumenumerating the different styles an operator can run : theirEnum.ordinal()reflects the level of confidence in their running mode