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 © 2017. All rights reserved.