See: Description
Interface | Description |
---|---|
CorePublisher<T> |
A
CoreSubscriber aware publisher. |
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. |
Enum | Description |
---|---|
Scannable.Attr.RunStyle |
An
Enum enumerating the different styles an operator can run : their Enum.ordinal() reflects the level of confidence
in their running mode |
Exception | Description |
---|---|
Exceptions.SourceException |
A
Throwable that wraps the actual cause delivered via
Subscriber.onError(Throwable) in case of
Publisher s that themselves emit items of type
Publisher . |