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 |