Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Reactor.core Classes and Interfaces - 52 results found.
NameDescriptionTypePackageFramework
AbstractLifecycleDispatcherA Dispatcher that has a lifecycle.Classreactor.core.dispatchReactor
AgileWaitingStrategyA pair of slow and fast wait strategies to dynamically adapt to a given application loadSince:2.Classreactor.core.dispatch.waitReactor
AssertAssertion utility class that assists in validating arguments.Classreactor.core.supportReactor
CancelExceptionAn exception signal from downstream subscribers consuming data when their state is denying any additional event.Classreactor.core.processorReactor
CompletableBlockingQueueA LinkedQueue that supports a terminal state.Classreactor.core.queueReactor
CompletableLinkedQueueA LinkedQueue that supports a terminal state.Classreactor.core.queueReactor
CompletableQueueQueues that support a terminal stateSince:2.Interfacereactor.core.queueReactor
ConfigurationReaderA ConfigurationReader is used to read Reactor configuration.Interfacereactor.core.configReactor
DispatcherA Dispatcher is used to dispatch(Object, Consumer, Consumer) dispatch} data to Consumers.Interfacereactor.coreReactor
DispatcherConfigurationAn encapsulation of the configuration for a Dispatcher.Classreactor.core.configReactor
DispatcherSupplierA Dispatcher Supplier with shutdown capacities to clean produced dispatchers.Interfacereactor.coreReactor
DispatcherTypeAn enumeration of supported types of Dispatcher.Classreactor.core.configReactor
ExceptionsStatic Helpers to decorate an exception with an associated data Original design from https://github.Classreactor.core.supportReactor
Exceptions .ValueCauseRepresents 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.Classreactor.core.supportReactor
ExecutorPoweredProcessorA base processor used by executor backed processors to take care of their ExecutorServiceAuthor:Stephane MaldiniClassreactor.core.processorReactor
InsufficientCapacityExceptionException thrown when the it is not possible to dispatch a signal a Dispatcher.Classreactor.core.processorReactor
MpscDispatcher queue tasks to execute.Classreactor.core.dispatchReactor
MpscLinkedQueueA MultiProduceSingleConsumer impl.Classreactor.core.queue.internalReactor
MpscLinkedQueueNodeClassreactor.core.queue.internalReactor
MultiThreadDispatcherBase implementation for multi-threaded dispatchersSince:1.Classreactor.core.dispatchReactor
MutableSignalClassreactor.core.processorReactor
MutableSignal .TypeReturns the enum constant of this type with the specified name.Classreactor.core.processorReactor
NamedDaemonThreadFactoryA thread factory that creates named daemon threads.Classreactor.core.supportReactor
NonBlockingA dispatcher aware componentAuthor:Stephane MaldiniInterfacereactor.core.supportReactor
ParkWaitStrategyClassreactor.core.dispatch.waitReactor
PlatformDependentBorrowed from Netty project which itself borrows from JCTools and various other projects.Classreactor.core.internalReactor
PropertiesConfigurationReaderA ConfigurationReader that reads the configuration from properties files and System properties.Classreactor.core.configReactor
PublisherFactoryA 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.Classreactor.core.reactivestreamsReactor
PublisherFactory .PrematureCompleteExceptionClassreactor.core.reactivestreamsReactor
ReactorConfigurationAn encapsulation of configuration for ReactorAuthor:Andy Wilkinson, Jon BrisbinClassreactor.core.configReactor
ReactorFatalExceptionan exception that should stop producing more dataSince:2.Classreactor.core.supportReactor
ReactorProcessorClassreactor.core.processorReactor
RecyclableA simple interface that marks an object as being recyclable.Interfacereactor.core.supportReactor
RingBufferDispatcherClassreactor.core.dispatchReactor
RingBufferProcessorAn implementation of a RingBuffer backed message-passing Processor.Classreactor.core.processorReactor
RingBufferSubscriberUtilsUtility methods to perform common tasks associated with Subscriber handling when the signals are stored in a com.Classreactor.core.processor.utilReactor
RingBufferWorkProcessorAn implementation of a RingBuffer backed message-passing WorkProcessor.Classreactor.core.processorReactor
SerializedSubscriberEnforces single-threaded, serialized, ordered execution of onNext(T), onComplete(), onError(java.Classreactor.core.reactivestreamsReactor
SingleThreadDispatcherBase Implementation for single-threaded Dispatchers.Classreactor.core.dispatchReactor
SingleUseExecutorClassreactor.core.processor.utilReactor
SpecificationExceptionsClassreactor.core.supportReactor
SubscriberBarrierA Subscriber with an asymetric typed wrapped subscriber.Classreactor.core.reactivestreamsReactor
SubscriberFactoryA 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.Classreactor.core.reactivestreamsReactor
SubscriberWithContextA Subscriber with a typed stateful context.Classreactor.core.reactivestreamsReactor
SubscriptionWithContextA Subscription with a typed stateful context.Classreactor.core.reactivestreamsReactor
SynchronousDispatcherA Dispatcher implementation that dispatches events using the calling thread.Classreactor.core.dispatchReactor
TailRecurseDispatcherA Dispatcher implementation that trampolines events using the calling thread and.Classreactor.core.dispatchReactor
ThreadPoolExecutorDispatcherA Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events.Classreactor.core.dispatchReactor
TraceableDelegatingDispatcherAn implementation of Dispatcher that traces activity through it.Classreactor.core.dispatchReactor
UUIDUtilsHelper for creating random and Type 1 (time-based) UUIDs.Classreactor.core.supportReactor
WaitingMoodA Component with some waiting capacities such as Dispatcher that uses a CPU-friendly strategy (e.Interfacereactor.core.dispatch.waitReactor
WorkQueueDispatcherClassreactor.core.dispatchReactor