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.