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 component that is forking to a sub-flow given a delegate input and that is consuming from a given delegate output
A component that will emit events to N downstreams.
A component that is linked to N upstreams producers.
A component that will emit events to a downstream.
A component that is linked to a source producer.
A lifecycle backed downstream
Global Reactor Core Exception handling and utils to operate on.