#Reactor.core Classes and Interfaces

_{#Reactor.core Classes and Interfaces - 52 results found.}

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

Search Java Classes and Packages