Indicates that a task or resource can be cancelled/disposed.
A micro API for stream fusion, in particular marks producers that support a
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.
Global Reactor Core Exception handling and utils to operate on.
Base class for