| Package | Description |
|---|---|
| reactor.core |
Core components of the Reactor framework.
|
| reactor.core.dispatch |
Dispatchers provide a way for work to be done in another thread,
but unlike a standard thread pool, do so with extreme efficiency. |
| reactor.core.processor |
This package offers a suite of asynchronous
Processor with backpressure support. |
| reactor.core.processor.util |
| Class and Description |
|---|
| InsufficientCapacityException
Exception thrown when the it is not possible to dispatch a signal a
Dispatcher. |
| Class and Description |
|---|
| InsufficientCapacityException
Exception thrown when the it is not possible to dispatch a signal a
Dispatcher. |
| Class and Description |
|---|
| CancelException
An exception signal from downstream subscribers consuming data when their state is denying any additional event.
|
| ExecutorPoweredProcessor
A base processor used by executor backed processors to take care of their ExecutorService
|
| InsufficientCapacityException
Exception thrown when the it is not possible to dispatch a signal a
Dispatcher. |
| MutableSignal.Type |
| ReactorProcessor
A base processor
|
| RingBufferProcessor
An implementation of a RingBuffer backed message-passing Processor.
|
| RingBufferWorkProcessor
An implementation of a RingBuffer backed message-passing WorkProcessor.
|
| Class and Description |
|---|
| MutableSignal |
Copyright © 2016. All rights reserved.