Name | Description | Type | Package | Framework |
AbstractLifecycleDispatcher | A Dispatcher that has a lifecycle. | Class | reactor.core.dispatch | Reactor |
|
AgileWaitingStrategy | A pair of slow and fast wait strategies to dynamically adapt to a given application loadSince:2. | Class | reactor.core.dispatch.wait | Reactor |
|
Assert | Assertion utility class that assists in validating arguments. | Class | reactor.core.support | Reactor |
|
CancelException | An exception signal from downstream subscribers consuming data when their state is denying any additional event. | Class | reactor.core.processor | Reactor |
|
CompletableBlockingQueue | A LinkedQueue that supports a terminal state. | Class | reactor.core.queue | Reactor |
|
CompletableLinkedQueue | A LinkedQueue that supports a terminal state. | Class | reactor.core.queue | Reactor |
|
CompletableQueue | Queues that support a terminal stateSince:2. | Interface | reactor.core.queue | Reactor |
|
ConfigurationReader | A ConfigurationReader is used to read Reactor configuration. | Interface | reactor.core.config | Reactor |
|
Dispatcher | A Dispatcher is used to dispatch(Object, Consumer, Consumer) dispatch} data to Consumers. | Interface | reactor.core | Reactor |
|
DispatcherConfiguration | An encapsulation of the configuration for a Dispatcher. | Class | reactor.core.config | Reactor |
|
DispatcherSupplier | A Dispatcher Supplier with shutdown capacities to clean produced dispatchers. | Interface | reactor.core | Reactor |
|
DispatcherType | An enumeration of supported types of Dispatcher. | Class | reactor.core.config | Reactor |
|
Exceptions | Static Helpers to decorate an exception with an associated data Original design from https://github. | Class | reactor.core.support | Reactor |
|
Exceptions .ValueCause | Represents an exception that was encountered while trying to emit an item from an Observable, and tries to preserve that item for future use and/or reporting. | Class | reactor.core.support | Reactor |
|
ExecutorPoweredProcessor | A base processor used by executor backed processors to take care of their ExecutorServiceAuthor:Stephane Maldini | Class | reactor.core.processor | Reactor |
|
InsufficientCapacityException | Exception thrown when the it is not possible to dispatch a signal a Dispatcher. | Class | reactor.core.processor | Reactor |
|
MpscDispatcher | queue tasks to execute. | Class | reactor.core.dispatch | Reactor |
|
MpscLinkedQueue | A MultiProduceSingleConsumer impl. | Class | reactor.core.queue.internal | Reactor |
|
MpscLinkedQueueNode | | Class | reactor.core.queue.internal | Reactor |
|
MultiThreadDispatcher | Base implementation for multi-threaded dispatchersSince:1. | Class | reactor.core.dispatch | Reactor |
|
MutableSignal | | Class | reactor.core.processor | Reactor |
|
MutableSignal .Type | Returns the enum constant of this type with the specified name. | Class | reactor.core.processor | Reactor |
|
NamedDaemonThreadFactory | A thread factory that creates named daemon threads. | Class | reactor.core.support | Reactor |
|
NonBlocking | A dispatcher aware componentAuthor:Stephane Maldini | Interface | reactor.core.support | Reactor |
|
ParkWaitStrategy | | Class | reactor.core.dispatch.wait | Reactor |
|
PlatformDependent | Borrowed from Netty project which itself borrows from JCTools and various other projects. | Class | reactor.core.internal | Reactor |
|
PropertiesConfigurationReader | A ConfigurationReader that reads the configuration from properties files and System properties. | Class | reactor.core.config | Reactor |
|
PublisherFactory | A Reactive Streams Publisher factory which callbacks on start, request and shutdown The Publisher will directly forward all the signals passed to the subscribers and complete when onComplete is called. | Class | reactor.core.reactivestreams | Reactor |
|
PublisherFactory .PrematureCompleteException | | Class | reactor.core.reactivestreams | Reactor |
|
ReactorConfiguration | An encapsulation of configuration for ReactorAuthor:Andy Wilkinson, Jon Brisbin | Class | reactor.core.config | Reactor |
|
ReactorFatalException | an exception that should stop producing more dataSince:2. | Class | reactor.core.support | Reactor |
|
ReactorProcessor | | Class | reactor.core.processor | Reactor |
|
Recyclable | A simple interface that marks an object as being recyclable. | Interface | reactor.core.support | Reactor |
|
RingBufferDispatcher | | Class | reactor.core.dispatch | Reactor |
|
RingBufferProcessor | An implementation of a RingBuffer backed message-passing Processor. | Class | reactor.core.processor | Reactor |
|
RingBufferSubscriberUtils | Utility methods to perform common tasks associated with Subscriber handling when the signals are stored in a com. | Class | reactor.core.processor.util | Reactor |
|
RingBufferWorkProcessor | An implementation of a RingBuffer backed message-passing WorkProcessor. | Class | reactor.core.processor | Reactor |
|
SerializedSubscriber | Enforces single-threaded, serialized, ordered execution of onNext(T), onComplete(), onError(java. | Class | reactor.core.reactivestreams | Reactor |
|
SingleThreadDispatcher | Base Implementation for single-threaded Dispatchers. | Class | reactor.core.dispatch | Reactor |
|
SingleUseExecutor | | Class | reactor.core.processor.util | Reactor |
|
SpecificationExceptions | | Class | reactor.core.support | Reactor |
|
SubscriberBarrier | A Subscriber with an asymetric typed wrapped subscriber. | Class | reactor.core.reactivestreams | Reactor |
|
SubscriberFactory | A Reactive Streams Subscriber factory which callbacks on start, onNext, onError and shutdown The Publisher will directly forward all the signals passed to the subscribers and complete when onComplete is called. | Class | reactor.core.reactivestreams | Reactor |
|
SubscriberWithContext | A Subscriber with a typed stateful context. | Class | reactor.core.reactivestreams | Reactor |
|
SubscriptionWithContext | A Subscription with a typed stateful context. | Class | reactor.core.reactivestreams | Reactor |
|
SynchronousDispatcher | A Dispatcher implementation that dispatches events using the calling thread. | Class | reactor.core.dispatch | Reactor |
|
TailRecurseDispatcher | A Dispatcher implementation that trampolines events using the calling thread and. | Class | reactor.core.dispatch | Reactor |
|
ThreadPoolExecutorDispatcher | A Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events. | Class | reactor.core.dispatch | Reactor |
|
TraceableDelegatingDispatcher | An implementation of Dispatcher that traces activity through it. | Class | reactor.core.dispatch | Reactor |
|
UUIDUtils | Helper for creating random and Type 1 (time-based) UUIDs. | Class | reactor.core.support | Reactor |
|
WaitingMood | A Component with some waiting capacities such as Dispatcher that uses a CPU-friendly strategy (e. | Interface | reactor.core.dispatch.wait | Reactor |
|
WorkQueueDispatcher | | Class | reactor.core.dispatch | Reactor |