See: Description
| Interface | Description |
|---|---|
| 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 | 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. |