# Classes and Interfaces in #Reactor

_{# Classes and Interfaces in #Reactor - 312 results found.}

Name	Description	Type	Package	Framework
AbstractLifecycleDispatcher	A Dispatcher that has a lifecycle.	Class	reactor.core.dispatch	Reactor
AbstractReference	An abstract Reference implementation that does reference counting.	Class	reactor.alloc	Reactor
Action	An Action is a reactive component to subscribe to a Publisher and in particular to a Stream.	Class	reactor.rx.action	Reactor
AdaptiveConsumerAction		Class	reactor.rx.action.terminal	Reactor
AfterAction		Class	reactor.rx.action.passive	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
Allocator	An Allocator is responsible for returning to the caller a Reference to a reusable object or to provide a newly-created object, depending on the underlying allocation strategy.	Interface	reactor.alloc	Reactor
Assert	Assertion utility class that assists in validating arguments.	Class	reactor.core.support	Reactor
AsyncAppender	A Logback Appender implementation that uses a Reactor RingBufferProcessor to queue events to a single-writer thread.	Class	reactor.logback	Reactor
BarrierStream	A BarrierStream provides a type of Stream into which you can bind Consumers and Functions from arbitrary components.	Class	reactor.rx.stream	Reactor
BatchAction		Class	reactor.rx.action.aggregation	Reactor
BatchSubscription	A Subscription wrapper which requestAuthor:Stephane Maldini	Class	reactor.rx.subscription	Reactor
BehaviorBroadcaster	A Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.	Class	reactor.rx.broadcast	Reactor
BiConsumer		Interface	reactor.fn	Reactor
BiFunction		Interface	reactor.fn	Reactor
BiStreams	A Streams add-on to work with key/value pairs hydrated in Tuple2.	Class	reactor.rx	Reactor
Broadcaster	A Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.	Class	reactor.rx.broadcast	Reactor
Buffer	A Buffer is a general-purpose IO utility class that wraps a ByteBuffer.	Class	reactor.io.buffer	Reactor
BufferAction		Class	reactor.rx.action.aggregation	Reactor
BufferAllocator	An Allocator implementation that allocates Buffers.	Class	reactor.io.buffer	Reactor
BufferCodec		Class	reactor.io.codec	Reactor
BufferShiftAction		Class	reactor.rx.action.aggregation	Reactor
BufferShiftWhenAction		Class	reactor.rx.action.aggregation	Reactor
BufferWhenAction		Class	reactor.rx.action.aggregation	Reactor
Bus	Basic unit of event handling in Reactor.	Interface	reactor.bus	Reactor
BusPublisher	Emit signals whenever an Event arrives from the Selector topic from the Bus.	Class	reactor.bus.publisher	Reactor
ByteArrayCodec	A simple Codec implementation that turns a Buffer into a byte[] andAuthor:Jon Brisbin, Stephane Maldini	Class	reactor.io.codec	Reactor
CachableRegistration		Class	reactor.bus.registry	Reactor
CacheAction		Class	reactor.rx.action.aggregation	Reactor
CachingRegistry		Class	reactor.bus.registry	Reactor
CallbackAction		Class	reactor.rx.action.passive	Reactor
CallbackEvent	Simple Event implementation that attaches a callback to an Event and passes it to a delegate Consumer.	Class	reactor.bus.support	Reactor
CancelException	An exception signal from downstream subscribers consuming data when their state is denying any additional event.	Class	reactor.core.processor	Reactor
ChronicleQueuePersistor	A QueuePersistor implementation that uses a Java Chronicle IndexedChronicle to persist items in the queue.	Class	reactor.io.queue	Reactor
ChronicleReaderStream	queue tasks to execute.	Class	reactor.rx.stream.io	Reactor
ChronicleStream		Class	reactor.rx.stream.io	Reactor
ClassSelector		Class	reactor.bus.selector	Reactor
ClientSocketOptions		Class	reactor.io.net.config	Reactor
ClosureTupleConsumer		Class	reactor.groovy.support	Reactor
Codec	instance of IN and passing that to the given Consumer.	Class	reactor.io.codec	Reactor
CombineLatestAction		Class	reactor.rx.action.combination	Reactor
CommonSocketOptions	Encapsulates common socket options.	Class	reactor.io.net.config	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
CompositeAction	Create a Processor where a given head/tail couple is provided as a Stream (Input upstream) and Action (OutputSince:2.	Class	reactor.rx.action	Reactor
CompressionCodec		Class	reactor.io.codec.compress	Reactor
ConcatAction		Class	reactor.rx.action.combination	Reactor
ConfigurationReader	A ConfigurationReader is used to read Reactor configuration.	Interface	reactor.core.config	Reactor
Consumer		Interface	reactor.fn	Reactor
ConsumerAction		Class	reactor.rx.action.terminal	Reactor
ConsumerFilteringRouter	An Router that filters consumers before routing events toAuthor:Andy Wilkinson, Stephane Maldini	Class	reactor.bus.routing	Reactor
Control	An interface generally associated with a Stream terminal action such as Stream.	Interface	reactor.rx.action	Reactor
CountAction		Class	reactor.rx.action.metrics	Reactor
DatagramServer		Class	reactor.io.net.udp	Reactor
DefaultIfEmptyAction		Class	reactor.rx.action.transformation	Reactor
DefaultSubscriber		Class	reactor.rx.action.support	Reactor
DeferredStream	A Publisher supplier that will call the passed supplier on each subscribe call.	Class	reactor.rx.stream	Reactor
DelimitedCodec	An implementation of Codec that decodes by splitting a Buffer into segments based on a delimiter and encodes by appending its delimiter to each piece of output.	Class	reactor.io.codec	Reactor
DematerializeAction		Class	reactor.rx.action.transformation	Reactor
Dispatcher	A Dispatcher is used to dispatch(Object, Consumer, Consumer) dispatch} data to Consumers.	Interface	reactor.core	Reactor
DispatcherAction		Class	reactor.rx.action.control	Reactor
DispatcherComponentSpec	A generic environment-aware class for specifying components that need to be configured with an Environment and Dispatcher.	Class	reactor.bus.spec	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
DistinctAction		Class	reactor.rx.action.filter	Reactor
DistinctUntilChangedAction		Class	reactor.rx.action.filter	Reactor
DropSubscription	Relationship between a Stream (Publisher) and a Subscriber.	Class	reactor.rx.subscription	Reactor
DurableAsyncAppender	An AsyncAppender subclass that first writes a log event to a durable Chronicle using Java Chronicle before allowing the event to be queued.	Class	reactor.logback	Reactor
DurableLogUtility		Class	reactor.logback	Reactor
DynamicMergeAction		Class	reactor.rx.action.combination	Reactor
ElapsedAction		Class	reactor.rx.action.metrics	Reactor
ElementAtAction		Class	reactor.rx.action.filter	Reactor
Environment		Class	reactor	Reactor
ErrorAction		Class	reactor.rx.action.error	Reactor
ErrorReturnAction		Class	reactor.rx.action.error	Reactor
ErrorStream	A Stream that emits a sigle error signal.	Class	reactor.rx.stream	Reactor
ErrorWithValueAction		Class	reactor.rx.action.error	Reactor
Event	Wrapper for an object that needs to be processed by Consumers.	Class	reactor.bus	Reactor
EventAllocator	Generic Event Allocator.	Class	reactor.alloc	Reactor
EventBus	A reactor is an event gateway that allows other components to register Event Consumers that can subsequently be notified of events.	Class	reactor.bus	Reactor
EventBusSpec	A helper class for configuring a new EventBus.	Class	reactor.bus.spec	Reactor
EventConsumer	Simple Consumer implementation that pulls the data from an Event and passes it to a delegate Consumer.	Class	reactor.bus.support	Reactor
EventFactorySupplier	A Supplier implementation that instantiates Events based on Event data type.	Class	reactor.alloc	Reactor
EventRoutingComponentSpec	A generic environment-aware class for specifying components that need to be configured with an Environment, Dispatcher, and Router.	Class	reactor.bus.spec	Reactor
EventTimer	A hashed wheel timer implementation that uses a Registry and custom Selectors to determine when tasks should be executed.	Class	reactor.bus.timer	Reactor
Exceptions	Static Helpers to decorate an exception with an associated data Original design from https://github.	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
ExistsAction		Class	reactor.rx.action.conditional	Reactor
FallbackAction		Class	reactor.rx.action.error	Reactor
FanInAction	The best moment of my life so far, not.	Class	reactor.rx.action.combination	Reactor
FanInSubscription		Class	reactor.rx.action.combination	Reactor
FanOutSubscription	A composite subscription used to achieve pub/sub pattern.	Class	reactor.rx.subscription	Reactor
Filter	A Filter is used to filter a list of items.	Interface	reactor.bus.filter	Reactor
FilterAction		Class	reactor.rx.action.filter	Reactor
FinallyAction		Class	reactor.rx.action.passive	Reactor
FirstFilter	A Filter implementation that returns the first item.	Class	reactor.bus.filter	Reactor
FlowControlAction		Class	reactor.rx.action.control	Reactor
Frame		Class	reactor.io.codec	Reactor
FrameCodec	Codec for decoding data into length-field-based Frames.	Class	reactor.io.codec	Reactor
Function		Interface	reactor.fn	Reactor
Functions	Helper methods to provide syntax sugar for working with functional components in Reactor.	Class	reactor.fn	Reactor
FutureStream	A Stream that emits a result of a Future and then complete.	Class	reactor.rx.stream	Reactor
GroupByAction	Manage a dynamic registry of substreams for a given key extracted from the incoming data.	Class	reactor.rx.action.transformation	Reactor
GroupedStream	The Stream will complete or fail whever the parent groupBy action terminates itself.	Class	reactor.rx.stream	Reactor
GzipCodec		Class	reactor.io.codec.compress	Reactor
HashWheelTimer	Hash Wheel Timer, as per the paper: Hashed and hierarchical timing wheels:	Class	reactor.fn.timer	Reactor
HeaderResolver	Responsible for extracting any applicable headers from a key.	Interface	reactor.bus.selector	Reactor
Headers	Header names common to HTTP requests and responsesAuthor:Sebastien Deleuze	Interface	reactor.io.net.http.model	Reactor
HttpChannel	A Request/Response ChannelStream extension that provides for several helpers to control HTTP behavior and observe its metadata.	Class	reactor.io.net.http	Reactor
HttpClient	The base class for a Reactor-based Http client.	Class	reactor.io.net.http	Reactor
HttpException	An exception for signalling that an error occurred during a communication over HTTP protocolAuthor:Anatoly KadyshevSee Also:Serialized Form	Class	reactor.io.net.http	Reactor
HttpHeaders		Interface	reactor.io.net.http.model	Reactor
HttpSelector	A Selector to match against ServerRequestAuthor:Stephane Maldini	Class	reactor.io.net.http	Reactor
HttpServer	Base functionality needed by all servers that communicate with clients over HTTP.	Class	reactor.io.net.http	Reactor
IgnoreErrorAction		Class	reactor.rx.action.error	Reactor
InMemoryQueuePersistor	A QueuePersistor implementations that stores items in-memory.	Class	reactor.io.queue	Reactor
InsufficientCapacityException	Exception thrown when the it is not possible to dispatch a signal a Dispatcher.	Class	reactor.core.processor	Reactor
IO	A factory for Reactive basic IO operations such as File read/write, Byte read and Codec decoding.	Class	reactor.io	Reactor
IOStreams	A Streams add-on to work with IO components such as ChronicleStreams.	Class	reactor.rx	Reactor
IterableStream	A Stream that emits Iterable values one by one and then complete.	Class	reactor.rx.stream	Reactor
JacksonJsonCodec		Class	reactor.io.codec.json	Reactor
JavaSerializationCodec	Codec to transform Java objects into Buffers and visa-versa.	Class	reactor.io.codec	Reactor
JsonCodec	A codec for decoding JSON into Java objects and encoding Java objects into JSON.	Class	reactor.io.codec.json	Reactor
JsonPathSelector		Class	reactor.bus.selector	Reactor
KryoCodec		Class	reactor.io.codec.kryo	Reactor
KryoPoolCodec		Class	reactor.io.codec.kryo	Reactor
LastAction		Class	reactor.rx.action.aggregation	Reactor
LengthFieldCodec	A codec that uses a length-field at the start of each chunk to denote the chunk's size.	Class	reactor.io.codec	Reactor
LiftStream	A Stream wrapper that defers a parent stream subscription to the child action subscribe() call.	Class	reactor.rx.stream	Reactor
LoggerAction		Class	reactor.rx.action.passive	Reactor
MapAction		Class	reactor.rx.action.transformation	Reactor
MapStream	A SubscribableMap is an event-driven Map that signals logged operations to its subscribers.	Class	reactor.rx.stream	Reactor
MatchAllSelector		Class	reactor.bus.selector	Reactor
MaterializeAction		Class	reactor.rx.action.transformation	Reactor
MergeAction		Class	reactor.rx.action.combination	Reactor
Method	A Model representation of supported HTTP MethodsAuthor:Sebastien Deleuze, Stephane Maldini	Class	reactor.io.net.http.model	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
NamedDaemonThreadFactory	A thread factory that creates named daemon threads.	Class	reactor.core.support	Reactor
NetSelectors	Helper methods for creating Selectors.	Class	reactor.io.net	Reactor
NetStreams	A Streams add-on to work with network facilities from reactor-net, e.	Class	reactor.io.net	Reactor
NettyChannelHandlerBridge	Netty ChannelInboundHandler implementation that passes data to a Reactor ChannelStream.	Class	reactor.io.net.impl.netty	Reactor
NettyChannelStream	ReactorChannel implementation that delegates to Netty.	Class	reactor.io.net.impl.netty	Reactor
NettyClientSocketOptions		Class	reactor.io.net.impl.netty	Reactor
NettyDatagramServer	DatagramServer implementation built on Netty.	Class	reactor.io.net.impl.netty.udp	Reactor
NettyHttpChannel		Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpClient	A Netty-based TcpClient.	Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpClientHandler		Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpHeaders		Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpResponseHeaders		Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpServer	A Netty-based TcpServer implementationAuthor:Jon Brisbin, Stephane Maldini	Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpServerHandler	Conversion between Netty types and Reactor types (NettyHttpChannel and Buffer).	Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpWSClientHandler		Class	reactor.io.net.impl.netty.http	Reactor
NettyHttpWSServerHandler	Conversion between Netty types and Reactor types (NettyHttpChannel and Buffer).	Class	reactor.io.net.impl.netty.http	Reactor
NettyNativeDetector		Class	reactor.io.net.impl.netty	Reactor
NettyServerSocketOptions		Class	reactor.io.net.impl.netty	Reactor
NettyTcpClient	A Netty-based TcpClient.	Class	reactor.io.net.impl.netty.tcp	Reactor
NettyTcpServer	A Netty-based TcpServer implementationAuthor:Jon Brisbin, Stephane Maldini	Class	reactor.io.net.impl.netty.tcp	Reactor
NonBlocking	A dispatcher aware componentAuthor:Stephane Maldini	Interface	reactor.core.support	Reactor
NotifyConsumer	A Consumer that notifies an observable of each value that it has accepted.	Class	reactor.bus.support	Reactor
ObjectSelector	Selector implementation that uses the Object.	Class	reactor.bus.selector	Reactor
ParkWaitStrategy		Class	reactor.core.dispatch.wait	Reactor
PassThroughCodec	A simple Codec that uses the source object as both input and output.	Class	reactor.io.codec	Reactor
PassThroughFilter	A Filter implementation that performs no filtering, returning the items as-is.	Class	reactor.bus.filter	Reactor
Pausable		Interface	reactor.fn	Reactor
PeriodicTimerStream	A Stream that emits 0 after an initial delay and ever incrementing long counter if the period argument is The TimerStream will manage dedicated timers for new subscriber assigned via	Class	reactor.rx.stream	Reactor
PersistentQueue	A PersistentQueue is a Queue implementation that delegates the actual storage of the elements in the queue to a QueuePersistor.	Class	reactor.io.queue	Reactor
PersistentQueueSpec	Helper spec to create a PersistentQueue instance.	Class	reactor.io.queue.spec	Reactor
PlatformDependent	Borrowed from Netty project which itself borrows from JCTools and various other projects.	Class	reactor.core.internal	Reactor
Predicate	Determines if the input object matches some criteria.	Interface	reactor.fn	Reactor
Predicates		Class	reactor.fn	Reactor
PredicateSelector		Class	reactor.bus.selector	Reactor
Promise	A Promise is a stateful event container that accepts a single value or error.	Class	reactor.rx	Reactor
Promises	Helper methods for creating Promise instances.	Class	reactor.rx	Reactor
PropertiesConfigurationReader	A ConfigurationReader that reads the configuration from properties files and System properties.	Class	reactor.core.config	Reactor
ProtobufCodec		Class	reactor.io.codec.protobuf	Reactor
Protocol	A Model representation of supported HTTP ProtocolsAuthor:Sebastien Deleuze, Stephane Maldini	Class	reactor.io.net.http.model	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
PublisherStream	A Publisher wrapper that takes care of lazy subscribing.	Class	reactor.rx.stream	Reactor
PushSubscription	Relationship between a Stream (Publisher) and a Subscriber.	Class	reactor.rx.subscription	Reactor
QueuePersistor	Persistence could be achieved through in-memory solutions like a Map or could be more complex and use a backing datastore.	Interface	reactor.io.queue	Reactor
RandomFilter	A Filter implementation that returns a single, randomly selected item.	Class	reactor.bus.filter	Reactor
RangeStream	A Stream that emits N Long from the inclusive start value defined to the inclusive end and then Since the stream retains the boundaries in a final field, any Subscriber	Class	reactor.rx.stream	Reactor
ReactiveSubscription	Relationship between a Stream (Publisher) and a Subscriber.	Class	reactor.rx.subscription	Reactor
ReactorChannelHandler	A ReactorChannel callback that is attached on ReactorPeer or ReactorClient initialization and receives all connected ReactorChannel.	Interface	reactor.io.net	Reactor
ReactorClient	A network-aware client that will publish its connection once available to the ReactorChannelHandler passed.	Class	reactor.io.net	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
ReactorPeer	Abstract base class that implements common functionality shared by clients and servers.	Class	reactor.io.net	Reactor
ReactorProcessor		Class	reactor.core.processor	Reactor
ReadableHeaders		Interface	reactor.io.net.http.model	Reactor
Reconnect	to the TcpClient whether or not to attempt to reconnect a broken connection.	Interface	reactor.io.net	Reactor
Recyclable	A simple interface that marks an object as being recyclable.	Interface	reactor.core.support	Reactor
RecyclableNumber		Class	reactor.alloc	Reactor
RecyclableString		Class	reactor.alloc	Reactor
ReduceByKeyAction		Class	reactor.rx.action.pair	Reactor
Reference	A Reference provides access to and metadata about a poolable object.	Interface	reactor.alloc	Reactor
ReferenceCountingAllocator	An implementation of Allocator that uses reference counting to determine when an object be recycled and placed back into the pool to be reused.	Class	reactor.alloc	Reactor
RegexSelector	A Selector implementation based on the given regular expression.	Class	reactor.bus.selector	Reactor
Registration	A Registration represents an object that has been registered with a Registry.	Interface	reactor.bus.registry	Reactor
Registries		Class	reactor.bus.registry	Reactor
Registry	use simple keys, they use Selectors to map their objects.	Interface	reactor.bus.registry	Reactor
RepeatAction		Class	reactor.rx.action.control	Reactor
RepeatWhenAction		Class	reactor.rx.action.control	Reactor
Resource	A Resource is a component with an active state, generally consuming hardware capacities (memory, cpu, io).	Interface	reactor.fn	Reactor
ResponseHeaders		Interface	reactor.io.net.http.model	Reactor
RetryAction		Class	reactor.rx.action.error	Reactor
RetryWhenAction		Class	reactor.rx.action.error	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
RoundRobinFilter	A Filter implementation that returns a single item.	Class	reactor.bus.filter	Reactor
Router	An Router is used to route an Object to Consumers.	Interface	reactor.bus.routing	Reactor
SampleAction		Class	reactor.rx.action.aggregation	Reactor
ScanAction		Class	reactor.rx.action.transformation	Reactor
ScanByKeyAction		Class	reactor.rx.action.pair	Reactor
Selector	A Selector is a wrapper around an arbitrary object.	Interface	reactor.bus.selector	Reactor
Selectors	Helper methods for creating Selectors.	Class	reactor.bus.selector	Reactor
SerializationCodec	Abstract base class for Codec Codecs that perform serialization of objects.	Class	reactor.io.codec	Reactor
SerializedBroadcaster	A Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.	Class	reactor.rx.broadcast	Reactor
SerializedSubscriber	Enforces single-threaded, serialized, ordered execution of onNext(T), onComplete(), onError(java.	Class	reactor.core.reactivestreams	Reactor
ServerSocketOptions	Encapsulates configuration options for server sockets.	Class	reactor.io.net.config	Reactor
SetMembershipSelector	objects on set membership.	Class	reactor.bus.selector	Reactor
Signal	A domain representation of a Reactive Stream signal.	Class	reactor.rx.action	Reactor
SimpleCachingRegistry	A naive caching Registry implementation for use in situations that the default CachingRegistry can't be used due to its reliance on the gs-collections library.	Class	reactor.bus.registry	Reactor
SingleThreadDispatcher	Base Implementation for single-threaded Dispatchers.	Class	reactor.core.dispatch	Reactor
SingleTimerStream	A Stream that emits 0 after an initial delay and then complete The SingleTimerStream will manage dedicated timers for new subscriber assigned via	Class	reactor.rx.stream	Reactor
SingleUseExecutor		Class	reactor.core.processor.util	Reactor
SingleValueStream	A Stream that emits only one value and then complete.	Class	reactor.rx.stream	Reactor
SkipAction		Class	reactor.rx.action.filter	Reactor
SkipUntilTimeout		Class	reactor.rx.action.filter	Reactor
SnappyCodec		Class	reactor.io.codec.compress	Reactor
SocketUtils	NOTE: This code is a copy of that available in the Spring Framework.	Class	reactor.io.net.tcp.support	Reactor
SortAction		Class	reactor.rx.action.aggregation	Reactor
Spec	Specifications used to build client and servers.	Interface	reactor.io.net	Reactor
SpecificationExceptions		Class	reactor.core.support	Reactor
SplitAction		Class	reactor.rx.action.transformation	Reactor
SSLEngineSupplier		Class	reactor.io.net.tcp.ssl	Reactor
SslOptions	Helper class encapsulating common SSL configuration options.	Class	reactor.io.net.config	Reactor
StandardCodecs	A selection of standard codecs.	Class	reactor.io.codec	Reactor
Status		Class	reactor.io.net.http.model	Reactor
StreamRouter		Class	reactor.groovy.config	Reactor
Streams	A public factory to build Stream, Streams provide for common transformations from a few structures such as Iterable or Future to a Stream, in addition to provide for combinatory operations (merge, switchOnNext.	Class	reactor.rx	Reactor
StreamStateCallbackAction		Class	reactor.rx.action.passive	Reactor
StreamUtils	A simple collection of utils to assist in various tasks such as DebuggingSince:1.	Class	reactor.rx	Reactor
StringCodec		Class	reactor.io.codec	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
Supplier	get() or can be created in some other way.	Interface	reactor.fn	Reactor
Suppliers	Helper class for working tying Suppliers to Iterables and other types ofCreate a Supplier that aggregates the given list of suppliers by calling each one, in	Class	reactor.fn	Reactor
SupplierStream	A Stream that returns the result from Supplier.	Class	reactor.rx.stream	Reactor
SwitchAction		Class	reactor.rx.action.combination	Reactor
SynchronousDispatcher	A Dispatcher implementation that dispatches events using the calling thread.	Class	reactor.core.dispatch	Reactor
SyslogCodec	A coded for consuming syslog messages.	Class	reactor.io.net.codec.syslog	Reactor
SyslogMessage		Class	reactor.io.net.codec.syslog	Reactor
TailRecurseDispatcher	A Dispatcher implementation that trampolines events using the calling thread and.	Class	reactor.core.dispatch	Reactor
TakeAction		Class	reactor.rx.action.filter	Reactor
TakeUntilTimeout		Class	reactor.rx.action.filter	Reactor
TakeWhileAction		Class	reactor.rx.action.filter	Reactor
Tap	A Tap provides a limited window into an event stream.	Class	reactor.fn.support	Reactor
TapAndControls		Class	reactor.rx.action.support	Reactor
TcpClient	The base class for a Reactor-based TCP client.	Class	reactor.io.net.tcp	Reactor
TcpServer	Base functionality needed by all servers that communicate with clients over TCP.	Class	reactor.io.net.tcp	Reactor
ThreadPoolExecutorDispatcher	A Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events.	Class	reactor.core.dispatch	Reactor
ThrottleRequestAction		Class	reactor.rx.action.control	Reactor
ThrottleRequestWhenAction		Class	reactor.rx.action.control	Reactor
TimeoutAction		Class	reactor.rx.action.error	Reactor
Timer		Interface	reactor.fn.timer	Reactor
TimestampAction		Class	reactor.rx.action.metrics	Reactor
TimeUtils		Class	reactor.fn.timer	Reactor
TraceableDelegatingDispatcher	An implementation of Dispatcher that traces activity through it.	Class	reactor.core.dispatch	Reactor
TraceableDelegatingFilter		Class	reactor.bus.filter	Reactor
TraceableDelegatingRouter		Class	reactor.bus.routing	Reactor
Transfer		Class	reactor.io.net.http.model	Reactor
Tuple	A Tuple is an immutable Collection of objects, each of which can be of an arbitrary type.	Class	reactor.fn.tuple	Reactor
Tuple1	A tuple that holds a single valueAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple2	A tuple that holds two valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple3	A tuple that holds three valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple4	A tuple that holds four valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple5	A tuple that holds five valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple6	A tuple that holds six valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple7	A tuple that holds seven valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
Tuple8	A tuple that holds eight valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
TupleN	A tuple that holds 9 or more valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized Form	Class	reactor.fn.tuple	Reactor
UriPathSelector	A Selector implementation based on a UriPathTemplate.	Class	reactor.bus.selector	Reactor
UriPathTemplate	Represents a URI template.	Class	reactor.bus.selector	Reactor
UriSelector	A Selector implementation that matches on various components of a full URI.	Class	reactor.bus.selector	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
WindowAction	WindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream.	Class	reactor.rx.action.aggregation	Reactor
WindowShiftAction	WindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream.	Class	reactor.rx.action.aggregation	Reactor
WindowShiftWhenAction	WindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream.	Class	reactor.rx.action.aggregation	Reactor
WindowWhenAction	WindowAction is forwarding events on a steam until returned stream emits a signal, after that streams collected events further, complete it and create a fresh new stream.	Class	reactor.rx.action.aggregation	Reactor
WorkQueueDispatcher		Class	reactor.core.dispatch	Reactor
WrappedSubscription		Class	reactor.rx.subscription.support	Reactor
WritableHeaders		Interface	reactor.io.net.http.model	Reactor
ZeroMQ		Class	reactor.io.net.impl.zmq.tcp	Reactor
ZeroMQChannelStream		Class	reactor.io.net.impl.zmq	Reactor
ZeroMQClientSocketOptions	ClientSocketOptions that include ZeroMQ-specific configuration options.	Class	reactor.io.net.impl.zmq	Reactor
ZeroMQServerSocketOptions	ServerSocketOptions that include ZeroMQ-specific configuration options.	Class	reactor.io.net.impl.zmq	Reactor
ZeroMQTcpClient		Class	reactor.io.net.impl.zmq.tcp	Reactor
ZeroMQTcpServer		Class	reactor.io.net.impl.zmq.tcp	Reactor
ZeroMQWorker		Class	reactor.io.net.impl.zmq	Reactor
ZipAction		Class	reactor.rx.action.combination	Reactor

Search Java Classes and Packages