| 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. |
| Modifier and Type | Method and Description |
|---|---|
<E> void |
Dispatcher.tryDispatch(E data,
Consumer<E> eventConsumer,
Consumer<Throwable> errorConsumer)
Instruct the
Dispatcher to dispatch the data. |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractLifecycleDispatcher.Task |
MpscDispatcher.tryAllocateTask() |
protected AbstractLifecycleDispatcher.Task |
MultiThreadDispatcher.tryAllocateTask() |
protected AbstractLifecycleDispatcher.Task |
RingBufferDispatcher.tryAllocateTask() |
protected AbstractLifecycleDispatcher.Task |
WorkQueueDispatcher.tryAllocateTask() |
protected AbstractLifecycleDispatcher.Task |
AbstractLifecycleDispatcher.tryAllocateTask() |
<E> void |
AbstractLifecycleDispatcher.tryDispatch(E event,
Consumer<E> eventConsumer,
Consumer<Throwable> errorConsumer) |
| Modifier and Type | Method and Description |
|---|---|
static InsufficientCapacityException |
InsufficientCapacityException.get() |
Copyright © 2016. All rights reserved.