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, avoiding the usual request(1) for dropped values.
Contract queue-fusion based optimizations for supporting subscriptions.
Marker interface indicating that the target can return a value or null immediately and thus a viable target for assembly-time optimizations.
Base class for synchronous sources which have fixed size and can emit its 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.
A list of reserved keys for component state scanning