Index (reactor-core 1.1.6.RELEASE API)

$ A B C D E F G H I J K L M N O P Q R S T U V W X Y

$

$() - Static method in class reactor.event.selector.Selectors: A short-hand alias for Selectors.anonymous().
$(T) - Static method in class reactor.event.selector.Selectors: A short-hand alias for Selectors.object(T).
$(String, Object...) - Static method in class reactor.event.selector.Selectors: Creates a Selector based on the given string format and arguments.

A

AbstractLifecycleDispatcher - Class in reactor.event.dispatch: A Dispatcher that has a lifecycle.
AbstractLifecycleDispatcher() - Constructor for class reactor.event.dispatch.AbstractLifecycleDispatcher
AbstractLifecycleDispatcher.Task - Class in reactor.event.dispatch
AbstractMultiThreadDispatcher - Class in reactor.event.dispatch: Base implementation for multi-threaded dispatchers
AbstractMultiThreadDispatcher(int, int) - Constructor for class reactor.event.dispatch.AbstractMultiThreadDispatcher
AbstractMultiThreadDispatcher.MultiThreadTask - Class in reactor.event.dispatch
AbstractReference<T extends Recyclable> - Class in reactor.alloc: An abstract Reference implementation that does reference counting.
AbstractReference(T) - Constructor for class reactor.alloc.AbstractReference
AbstractSingleThreadDispatcher - Class in reactor.event.dispatch: Base Implementation for single-threaded Dispatchers.
AbstractSingleThreadDispatcher(int) - Constructor for class reactor.event.dispatch.AbstractSingleThreadDispatcher
AbstractSingleThreadDispatcher.SingleThreadTask - Class in reactor.event.dispatch
accept(Event<T>) - Method in class reactor.core.action.Action
accept(Throwable) - Method in class reactor.core.composable.Deferred: Accepts the given error such that it can be consumed by the underlying Composable.
accept(T) - Method in class reactor.core.composable.Deferred: Accepts the given value such that it can be consumed by the underlying Composable.
accept(Object) - Method in class reactor.core.fork.ForkJoinTask
accept(E) - Method in class reactor.core.Reactor.ReplyToConsumer
accept(T) - Method in class reactor.core.support.NotifyConsumer
accept(Event<T>) - Method in class reactor.event.support.EventConsumer
accept(T) - Method in interface reactor.function.Consumer: Execute the logic of the action, accepting the given parameter.
accept(T) - Method in class reactor.function.support.DelegatingConsumer
accept(long, T) - Method in class reactor.function.support.Resequencer: Accept and possibly queue a value for the given slot.
accept(T) - Method in class reactor.function.support.SingleUseConsumer
accept(T) - Method in class reactor.function.support.Tap
acceptEvent(Event<T>) - Method in class reactor.core.composable.Deferred: Accepts the given value such that it can be consumed by the underlying Composable.
Action<T> - Class in reactor.core.action: Base class for all Composable actions such as map, reduce, filter...
Action(Observable, Object, Object) - Constructor for class reactor.core.action.Action
Action(Observable, Object) - Constructor for class reactor.core.action.Action
ActionUtils - Class in reactor.core.action
ActionUtils() - Constructor for class reactor.core.action.ActionUtils
ActionUtils.ActionVisitor - Class in reactor.core.action
ActorDispatcher - Class in reactor.event.dispatch: An implementation of Dispatcher that maps a key to a delegate dispatcher and caches the mapping within its internal Registry.
ActorDispatcher(Function<Object, Dispatcher>) - Constructor for class reactor.event.dispatch.ActorDispatcher
actorSystem(String) - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the component to use an Environment based ActorDispatcher.
actorSystem(Function<Object, Dispatcher>) - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the component to use an ActorDispatcher.
add(Action<T>) - Method in interface reactor.core.action.Pipeline: Consume events with the passed Action
add(Action<T>) - Method in class reactor.core.composable.Composable: Consume events with the passed Action
add(Action<T>) - Method in class reactor.core.composable.Promise
add(Function<V, T>) - Method in class reactor.core.fork.ForkJoinTask: Add a task to the collection of tasks to be executed.
add(Consumer<T>) - Method in class reactor.function.support.DelegatingConsumer: Add the given Consumer to the list of delegates.
add(Collection<Consumer<T>>) - Method in class reactor.function.support.DelegatingConsumer: Add the given Consumers to the list of delegates.
add(K, V) - Method in class reactor.util.LinkedMultiValueMap
add(K, V) - Method in interface reactor.util.MultiValueMap: Add the given single value to the current list of values for the given key.
addDispatcher(String, Dispatcher) - Method in class reactor.core.Environment: Adds the dispatcher to the environment, storing it using the given name.
addObjectToArray(A[], O) - Static method in class reactor.util.ObjectUtils: Append the given object to the given array, returning a new array consisting of the input array contents plus the given object.
addStringToArray(String[], String) - Static method in class reactor.util.StringUtils: Append the given String to the given String array, returning a new array consisting of the input array contents plus the given String.
addToTailRecursionPile(AbstractLifecycleDispatcher.Task) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
addToTailRecursionPile(AbstractLifecycleDispatcher.Task) - Method in class reactor.event.dispatch.AbstractMultiThreadDispatcher
alive() - Method in class reactor.alloc.RingBufferAllocator
alive() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
alive() - Method in class reactor.event.dispatch.ActorDispatcher
alive() - Method in interface reactor.event.dispatch.Dispatcher: Determine whether this Dispatcher can be used for dispatching.
alive() - Method in class reactor.event.dispatch.SynchronousDispatcher
alive() - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
allocate() - Method in interface reactor.alloc.Allocator: Allocate an object from the internal pool.
allocate() - Method in class reactor.alloc.PartitionedAllocator
allocate() - Method in class reactor.alloc.ReferenceCountingAllocator
allocate() - Method in class reactor.alloc.RingBufferAllocator
allocate() - Method in class reactor.io.BufferAllocator
allocate() - Method in class reactor.pool.LoadingPool: Deprecated.
allocate() - Method in interface reactor.pool.Pool: Deprecated.

Allocates a new object from the pool.
allocateBatch(int) - Method in interface reactor.alloc.Allocator: Allocate a batch of objects all at once.
allocateBatch(int) - Method in class reactor.alloc.PartitionedAllocator
allocateBatch(int) - Method in class reactor.alloc.ReferenceCountingAllocator
allocateBatch(int, List<Reference<T>>) - Method in class reactor.alloc.RingBufferAllocator
allocateBatch(int) - Method in class reactor.alloc.RingBufferAllocator
allocateBatch(int) - Method in class reactor.io.BufferAllocator
allocateRecursiveTask() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
allocateRecursiveTask() - Method in class reactor.event.dispatch.AbstractMultiThreadDispatcher
allocateRecursiveTask() - Method in class reactor.event.dispatch.AbstractSingleThreadDispatcher
allocateTask() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
allocateTask() - Method in class reactor.event.dispatch.AbstractMultiThreadDispatcher
allocateTask() - Method in class reactor.event.dispatch.AbstractSingleThreadDispatcher
allocateTask() - Method in class reactor.event.dispatch.RingBufferDispatcher
allocateTask() - Method in class reactor.event.dispatch.WorkQueueDispatcher
Allocator<T extends Recyclable> - Interface in reactor.alloc: 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.
allocator(Supplier<T>) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: The Supplier to provide the RingBuffer with the reusable objects that are being pooled.
and(Predicate<? super T>...) - Static method in class reactor.function.Predicates: Returns a Predicate which evaluates to true only if all the provided predicates evaluate to true.
AnnotationUtils - Class in reactor.core.dynamic.reflect.support: Utility methods for working with Annotations.
anonymous() - Static method in class reactor.event.selector.Selectors: Creates an anonymous Selector.
AnonymousKey() - Constructor for class reactor.event.selector.Selectors.AnonymousKey
any(Deferred<T, Promise<T>>...) - Static method in class reactor.core.composable.spec.Promises: Pick the first result coming from any of the given promises and populate a new Promise.
any(Promise<T>...) - Static method in class reactor.core.composable.spec.Promises: Pick the first result coming from any of the given promises and populate a new Promise.
any(Collection<? extends Promise<T>>) - Static method in class reactor.core.composable.spec.Promises: Pick the first result coming from any of the given promises and populate a new Promise.
append(String) - Method in class reactor.io.Buffer: Append the given String to this Buffer.
append(short) - Method in class reactor.io.Buffer: Append the given short to this Buffer.
append(int) - Method in class reactor.io.Buffer: Append the given int to this Buffer.
append(long) - Method in class reactor.io.Buffer: Append the given long to this Buffer.
append(char) - Method in class reactor.io.Buffer: Append the given char to this Buffer.
append(ByteBuffer...) - Method in class reactor.io.Buffer: Append the given ByteBuffer to this Buffer.
append(Buffer...) - Method in class reactor.io.Buffer: Append the given Buffer to this Buffer.
append(byte) - Method in class reactor.io.Buffer: Append the given byte to this Buffer.
append(byte[]) - Method in class reactor.io.Buffer: Append the given byte[] to this Buffer.
append(byte[], int, int) - Method in class reactor.io.Buffer: Append the given byte[] to this Buffer, starting at the given index and continuing for the given length.
apply(Method) - Method in class reactor.core.dynamic.reflect.SimpleMethodNotificationKeyResolver
apply(Method) - Method in class reactor.core.dynamic.reflect.SimpleMethodSelectorResolver
apply(T) - Method in interface reactor.function.Function: Execute the logic of the action, accepting the given parameter.
applyRelativePath(String, String) - Static method in class reactor.util.StringUtils: Apply the given relative path to the given path, assuming standard Java folder separation (i.e.
approxCurrentTimeMillis() - Static method in class reactor.timer.TimeUtils
ArgumentConvertingConsumerInvoker - Class in reactor.event.routing: This implementation of a ConsumerInvoker will attempt to invoke a Consumer as-is and, if that fails with a ClassCastException because the argument declared in the Consumer isn't of the correct type, it tries to find an object of that type in the array of possible arguments passed to the invoker.
ArgumentConvertingConsumerInvoker(Converter) - Constructor for class reactor.event.routing.ArgumentConvertingConsumerInvoker: Creates a new ArgumentConvertingConsumerInvoker that will use the given converter for any necessary argument conversion.
arrayToCommaDelimitedString(Object[]) - Static method in class reactor.util.StringUtils: Convenience method to return a String array as a CSV String.
arrayToDelimitedString(Object[], String) - Static method in class reactor.util.StringUtils: Convenience method to return a String array as a delimited (e.g.
arrayToList(Object) - Static method in class reactor.util.CollectionUtils: Convert the supplied array into a List.
asBytes() - Method in class reactor.io.Buffer: Return the contents of this buffer copied into a byte[].
asMap() - Method in class reactor.event.Event.Headers: Get these headers as an unmodifiable Map.
Assert - Class in reactor.util: Assertion utility class that assists in validating arguments.
Assert() - Constructor for class reactor.util.Assert
asString() - Method in class reactor.io.Buffer: Convert the contents of this buffer into a String using a UTF-8 CharsetDecoder.
await() - Method in class reactor.core.composable.Promise: Block the calling thread, waiting for the completion of this Promise.
await(long, TimeUnit) - Method in class reactor.core.composable.Promise: Block the calling thread for the specified time, waiting for the completion of this Promise.
await() - Method in class reactor.function.support.Boundary: Wait for all latches to be counted down (almost) indefinitely.
await(long, TimeUnit) - Method in class reactor.function.support.Boundary: Wait for all latches to be counted down within the given timeout window.
awaitAndShutdown() - Method in class reactor.alloc.RingBufferAllocator
awaitAndShutdown(long, TimeUnit) - Method in class reactor.alloc.RingBufferAllocator
awaitAndShutdown() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
awaitAndShutdown() - Method in class reactor.event.dispatch.ActorDispatcher
awaitAndShutdown(long, TimeUnit) - Method in class reactor.event.dispatch.ActorDispatcher
awaitAndShutdown() - Method in interface reactor.event.dispatch.Dispatcher: Block until all submitted tasks have completed, then do a normal Dispatcher.shutdown().
awaitAndShutdown(long, TimeUnit) - Method in interface reactor.event.dispatch.Dispatcher: Block until all submitted tasks have completed, then do a normal Dispatcher.shutdown().
awaitAndShutdown(long, TimeUnit) - Method in class reactor.event.dispatch.RingBufferDispatcher
awaitAndShutdown() - Method in class reactor.event.dispatch.SynchronousDispatcher
awaitAndShutdown(long, TimeUnit) - Method in class reactor.event.dispatch.SynchronousDispatcher
awaitAndShutdown(long, TimeUnit) - Method in class reactor.event.dispatch.ThreadPoolExecutorDispatcher
awaitAndShutdown() - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
awaitAndShutdown(long, TimeUnit) - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
awaitAndShutdown(long, TimeUnit) - Method in class reactor.event.dispatch.WorkQueueDispatcher

B

basePath(String) - Method in class reactor.queue.spec.PersistentQueueSpec
batch(int, Consumer<T>) - Method in class reactor.core.processor.Processor: If the Consumer set in the spec is a BatchConsumer, then the start method will be invoked before the batch is published, then all the events of the batch are published to the consumer, then the batch end is published.
BatchAction<T> - Class in reactor.core.action
BatchAction(int, Observable, Object, Object) - Constructor for class reactor.core.action.BatchAction
BatchAction(int, Observable, Object, Object, Object, Object) - Constructor for class reactor.core.action.BatchAction
BatchConsumer<T> - Interface in reactor.function.batch: Consumer that is notified of the start and end of a batch.
batcher() - Method in class reactor.core.composable.Deferred: Return a Consumer that accepts a sequence of events before notifying the Composable whom must be a Stream
batcher(int) - Method in class reactor.core.composable.Deferred: Return a Consumer that accepts a sequence of events before notifying the Composable whom must be a Stream
BatchFactorySupplier<T> - Class in reactor.alloc.factory: Simple Supplier implementation that fills a fixed-size array with pre-allocated objects, which are handed out, one after the other, until the array is exhausted.
BatchFactorySupplier(int, Supplier<T>) - Constructor for class reactor.alloc.factory.BatchFactorySupplier
batchNotify(Object) - Method in interface reactor.core.Observable: Notify the key with all any accepted iterable group of events by the returned Consumer.
batchNotify(Object, Consumer<Void>) - Method in interface reactor.core.Observable: Notify the key with all any accepted iterable group of events by the returned Consumer.
batchNotify(Object) - Method in class reactor.core.Reactor
batchNotify(Object, Consumer<Void>) - Method in class reactor.core.Reactor
batchSize(int) - Method in class reactor.core.composable.spec.DeferredStreamSpec: Configures the stream to have the given batchSize.
batchSize(int) - Method in class reactor.core.composable.spec.StreamSpec: Configures the stream to have the given batchSize.
batchSize - Variable in class reactor.core.composable.Stream
beforeAccept(SRC) - Method in class reactor.io.encoding.PassThroughCodec: Override to intercept the source object before it is passed into the next Consumer or returned to the caller if a Consumer is not set.
beforeApply(SRC) - Method in class reactor.io.encoding.PassThroughCodec: Override to intercept the source object before it is returned for output.
bind(Consumer<T>) - Method in class reactor.function.support.Boundary: Bind the given Consumer to this Boundary by creating a CountDownLatch that will be counted down the first time the given Consumer is invoked.
bind(Consumer<T>, int) - Method in class reactor.function.support.Boundary: Bind the given Consumer to this Boundary by creating a CountDownLatch of the given size that will be counted down the every time the given Consumer is invoked.
BlockingQueueFactory - Class in reactor.queue: A factory for creating BlockingQueue instances.
BlockingQueueFactory() - Constructor for class reactor.queue.BlockingQueueFactory
blockingWaitStrategy() - Method in class reactor.core.processor.spec.ProcessorSpec: Set BlockingWaitStrategy as wait strategy.
Boundary - Class in reactor.function.support: A Boundary is a blocking utility that allows the user to bind an arbitrary number of Consumers to it.
Boundary() - Constructor for class reactor.function.support.Boundary
broadcastEventRouting() - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's EventRouter to broadcast events to all matching consumers
browseAction(Action) - Static method in class reactor.core.action.ActionUtils
browseReactor(Reactor) - Static method in class reactor.core.action.ActionUtils
browseReactor(Reactor, Object, Object, Object) - Static method in class reactor.core.action.ActionUtils
buffer() - Method in class reactor.core.composable.Stream: Use Observable.batchNotify(Object) to group dispatching by the current batch size.
buffer(int) - Method in class reactor.core.composable.Stream: Use Observable.batchNotify(Object) to group dispatch by the passed .
Buffer - Class in reactor.io: A Buffer is a general-purpose IO utility class that wraps a ByteBuffer.
Buffer() - Constructor for class reactor.io.Buffer: Create an empty Buffer that is dynamic.
Buffer(int, boolean) - Constructor for class reactor.io.Buffer: Create an Buffer that has an internal ByteBuffer allocated to the given size and optional make this buffer fixed-length.
Buffer(Buffer) - Constructor for class reactor.io.Buffer: Copy constructor that creates a shallow copy of the given Buffer by calling ByteBuffer.duplicate() on the underlying ByteBuffer.
Buffer(ByteBuffer) - Constructor for class reactor.io.Buffer: Create a Buffer using the given ByteBuffer as the inital source.
Buffer.View - Class in reactor.io: A View represents a segment of a buffer.
BUFFER_FLUSH - Static variable in class reactor.core.action.BufferAction
BufferAction<T> - Class in reactor.core.action
BufferAction(int, Observable, Object, Object, Object) - Constructor for class reactor.core.action.BufferAction
BufferAllocator - Class in reactor.io: An Allocator implementation that allocates Buffers.
BufferAllocator() - Constructor for class reactor.io.BufferAllocator: Create a BufferAllocator of size=256, direct=false, and bufferSize=Buffer.SMALL_BUFFER_SIZE.
BufferAllocator(int, boolean, int) - Constructor for class reactor.io.BufferAllocator: Create a BufferAllocator.
bufferWithErrors() - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed separately into the returned Stream every time batchSize has been reached.
bufferWithErrors(int) - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed separately into the returned Stream every time batchSize has been reached.
BusySpinWait() - Constructor for class reactor.timer.HashWheelTimer.BusySpinWait
busySpinWaitStrategy() - Method in class reactor.core.processor.spec.ProcessorSpec: Set BusySpinWaitStrategy as wait strategy.
BYTE_ARRAY_CODEC - Static variable in class reactor.io.encoding.StandardCodecs: A ByteArrayCodec.
ByteArrayCodec - Class in reactor.io.encoding: A simple Codec implementation that turns a Buffer into a byte[] and visa-versa.
ByteArrayCodec() - Constructor for class reactor.io.encoding.ByteArrayCodec
byteBuffer() - Method in class reactor.io.Buffer: Return the underlying ByteBuffer.

C

CachableRegistration<T> - Class in reactor.event.registry
CachableRegistration(Selector, T, Runnable) - Constructor for class reactor.event.registry.CachableRegistration
cacheLineSize(int) - Method in class reactor.queue.spec.PersistentQueueSpec
cacheMiss(Object) - Method in class reactor.event.registry.CachingRegistry
CachingRegistry<T> - Class in reactor.event.registry: Implementation of Registry that uses a partitioned cache that partitions on thread id.
CachingRegistry() - Constructor for class reactor.event.registry.CachingRegistry
CachingRegistry(boolean, boolean, Consumer<Object>) - Constructor for class reactor.event.registry.CachingRegistry
callback() - Method in class reactor.event.support.CallbackEvent: Trigger callback with current payload
CallbackAction<T> - Class in reactor.core.action
CallbackAction(Consumer<T>, Observable, Object) - Constructor for class reactor.core.action.CallbackAction
CallbackEvent<T> - Class in reactor.event.support: Simple Event implementation that attaches a callback to an Event and passes it to a delegate Consumer.
CallbackEvent(T, Consumer) - Constructor for class reactor.event.support.CallbackEvent
CallbackEvent(Event.Headers, T, Consumer) - Constructor for class reactor.event.support.CallbackEvent
CallbackEvent(Event.Headers, T, Consumer, Consumer<Throwable>) - Constructor for class reactor.event.support.CallbackEvent
CallbackEventAction<T> - Class in reactor.core.action
CallbackEventAction(Consumer<Event<T>>, Observable, Object) - Constructor for class reactor.core.action.CallbackEventAction
cancel() - Method in class reactor.core.action.WindowAction
cancel() - Method in interface reactor.event.lifecycle.Pausable: Cancel this Pausable.
cancel() - Method in class reactor.event.registry.CachableRegistration
cancel() - Method in interface reactor.event.registry.Registration: Cancel this Registration by removing it from its registry.
cancel() - Method in class reactor.timer.HashWheelTimer: Cancel current Timer
cancel() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Cancel the registration
cancel() - Method in class reactor.timer.SimpleHashWheelTimer
cancel() - Method in interface reactor.timer.Timer: Cancel this timer by interrupting the task thread.
cancelAfterUse() - Method in class reactor.event.registry.CachableRegistration
cancelAfterUse() - Method in interface reactor.event.registry.Registration: Cancel this Registration after it has been selected and used.
cancelAfterUse() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Cancel this HashWheelTimer.TimerRegistration after it has been selected and used.
CancelConsumerException - Exception in reactor.function.support
CancelConsumerException() - Constructor for exception reactor.function.support.CancelConsumerException
CancelConsumerException(String) - Constructor for exception reactor.function.support.CancelConsumerException
canConvert(Class<?>, Class<?>) - Method in interface reactor.convert.Converter: Returns true if objects of sourceType can be converted to targetType.
canConvert(Class<?>, Class<?>) - Method in class reactor.convert.DelegatingConverter
canConvert(Class<?>, Class<?>) - Method in enum reactor.convert.StandardConverters.ConstructorParameterConverter
canConvert(Class<?>, Class<?>) - Method in enum reactor.convert.StandardConverters.StringToNumberConverter
canConvert(Class<?>, Class<?>) - Method in enum reactor.convert.StandardConverters.ToStringConverter
capacity() - Method in class reactor.io.Buffer: Provides the current capacity of the internal ByteBuffer.
capitalize(String) - Static method in class reactor.util.StringUtils: Capitalize a String, changing the first letter to upper case as per Character.toUpperCase(char).
caseInsensitiveValueOf(E[], String) - Static method in class reactor.util.ObjectUtils: Case insensitive alternative to Enum.valueOf(Class, String).
chain(Consumer<T>...) - Static method in class reactor.function.Functions: Chain a set of Consumers together into a single Consumer.
ClassSelector - Class in reactor.event.selector: Implementation of Selector that uses Class.isAssignableFrom(Class) to determine a match.
ClassSelector(Class<?>) - Constructor for class reactor.event.selector.ClassSelector: Creates a new ClassSelector that will match keys that are the same as, or are a super type of the given type, i.e.
cleanPath(String) - Static method in class reactor.util.StringUtils: Normalize the path by suppressing sequences like "path/.." and inner simple dots.
clear() - Method in class reactor.event.registry.CachingRegistry
clear() - Method in interface reactor.event.registry.Registry: Clear the Registry, resetting its state and calling Registration.cancel() for any active Registration.
clear() - Method in class reactor.function.support.DelegatingConsumer: Clear all delegate Consumers from the list.
clear() - Method in class reactor.io.Buffer: Clear the internal ByteBuffer by setting the Buffer.position(int) to 0 and the limit to the current capacity.
clear() - Method in class reactor.util.LinkedCaseInsensitiveMap
clear() - Method in class reactor.util.LinkedMultiValueMap
clearOnStart(boolean) - Method in class reactor.queue.spec.PersistentQueueSpec
clone() - Method in class reactor.event.selector.ObjectSelector
close() - Method in class reactor.io.Buffer
close() - Method in class reactor.queue.IndexedChronicleQueuePersistor: Close the underlying chronicles.
close() - Method in class reactor.queue.InMemoryQueuePersistor
close() - Method in class reactor.queue.PersistentQueue: Close the underlying QueuePersistor and release any resources.
close() - Method in interface reactor.queue.QueuePersistor: Release any internal resources used by the persistence mechanism.
closeQuietly(Closeable...) - Static method in class reactor.util.IoUtils: Closes each of the closeables swallowing any IOExceptions that are thrown.
Codec<SRC,IN,OUT> - Interface in reactor.io.encoding: Implementations of a Codec are responsible for decoding a SRC into an instance of IN and passing that to the given Consumer.
codec(Codec<Buffer, T, T>) - Method in class reactor.queue.spec.PersistentQueueSpec
collect() - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed into the returned Stream every time batchSize or flush is triggered has been reached.
collect(int) - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed into the returned Stream every time batchSize has been reached.
collect(List<Supplier<T>>) - Static method in class reactor.function.Suppliers: Create a Supplier that aggregates the given list of suppliers by calling each one, in turn, until the supplier returns null.
collect() - Method in class reactor.util.PartitionedReferencePile
CollectAction<T> - Class in reactor.core.action
CollectAction(int, Observable, Object, Object) - Constructor for class reactor.core.action.CollectAction
collectionToCommaDelimitedString(Collection<?>) - Static method in class reactor.util.StringUtils: Convenience method to return a Collection as a CSV String.
collectionToDelimitedString(Collection<?>, String, String, String) - Static method in class reactor.util.StringUtils: Convenience method to return a Collection as a delimited (e.g.
collectionToDelimitedString(Collection<?>, String) - Static method in class reactor.util.StringUtils: Convenience method to return a Collection as a delimited (e.g.
CollectionUtils - Class in reactor.util: Miscellaneous collection utility methods.
CollectionUtils() - Constructor for class reactor.util.CollectionUtils
commaDelimitedListToSet(String) - Static method in class reactor.util.StringUtils: Convenience method to convert a CSV string list to a set.
commaDelimitedListToStringArray(String) - Static method in class reactor.util.StringUtils: Convert a CSV list into an array of Strings.
commit() - Method in class reactor.core.processor.Operation: Commit the Operation to the underlying datastructure.
commit(List<Operation<T>>) - Method in class reactor.core.processor.Processor: Commit a list of Operations by doing a batch publish.
compact() - Method in class reactor.io.Buffer: Compact the underlying ByteBuffer.
compareTo(Buffer) - Method in class reactor.io.Buffer
compareTo(Object) - Method in class reactor.timer.HashWheelTimer.TimerRegistration
completionConsumer - Variable in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
Composable<T> - Class in reactor.core.composable: Abstract base class for components designed to provide a succinct API for working with future values.
Composable(Observable, Composable<U>) - Constructor for class reactor.core.composable.Composable
Composable(Observable, Composable<U>, Tuple2<Selector, Object>, Environment) - Constructor for class reactor.core.composable.Composable
ComposableSpec<SPEC extends ComposableSpec<SPEC,TARGET>,TARGET> - Class in reactor.core.composable.spec: A helper class for specifying a bounded Composable.
ComposableSpec() - Constructor for class reactor.core.composable.spec.ComposableSpec
compose() - Method in class reactor.core.composable.Deferred: Returns the underlying Composable subclass from which values and errors can be consumed.
compose() - Method in class reactor.core.fork.ForkJoinTask: Compose actions against the asynchronous results.
CompressionCodec<IN,OUT> - Class in reactor.io.encoding.compress
CompressionCodec(Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.compress.CompressionCodec
concatenateStringArrays(String[], String[]) - Static method in class reactor.util.StringUtils: Concatenate the given String arrays into one, with overlapping array elements included twice.
ConfigurationReader - Interface in reactor.core.configuration: A ConfigurationReader is used to read Reactor configuration.
configure(Dispatcher, Environment) - Method in class reactor.core.composable.spec.ComposableSpec
configure(Reactor, Environment) - Method in class reactor.core.spec.ReactorSpec
configure(Dispatcher, Environment) - Method in class reactor.core.spec.support.DispatcherComponentSpec
configure(Reactor, Environment) - Method in class reactor.core.spec.support.EventRoutingComponentSpec
configure(Dispatcher, Environment) - Method in class reactor.core.spec.support.EventRoutingComponentSpec
connect(Composable<T>) - Method in class reactor.core.composable.Composable: Attach another Composable to this one that will cascade the value or error received by this Composable into the next.
connect(Composable<T>) - Method in class reactor.core.composable.Promise
connect(Composable<T>) - Method in class reactor.core.composable.Stream
ConnectAction<T> - Class in reactor.core.action
ConnectAction(Observable, Object, Object) - Constructor for class reactor.core.action.ConnectAction
connectErrors(Composable<?>) - Method in class reactor.core.composable.Composable: Forward any error to the argument.
connectErrors(Composable<?>) - Method in class reactor.core.composable.Promise
connectErrors(Composable<?>) - Method in class reactor.core.composable.Stream
connectValues(Composable<T>) - Method in class reactor.core.composable.Composable: Attach another Composable to this one that will only cascade the value received by this Composable into the next.
connectValues(Composable<T>) - Method in class reactor.core.composable.Stream
consume(Consumer<T>) - Method in class reactor.core.composable.Composable: Attach a Consumer to this Composable that will consume any values accepted by this Composable.
consume(Object, Observable) - Method in class reactor.core.composable.Composable: Pass values accepted by this Composable into the given Observable, notifying with the given key.
consume(Consumer<T>) - Method in class reactor.core.composable.Promise
consume(Object, Observable) - Method in class reactor.core.composable.Promise
consume(Consumer<T>) - Method in class reactor.core.composable.Stream
consume(Object, Observable) - Method in class reactor.core.composable.Stream
consume(Consumer<T>) - Method in class reactor.core.processor.spec.ProcessorSpec: When data is mutated and published into the Processor, invoke the given Consumer and pass the mutated data.
consumeError(Throwable) - Method in class reactor.event.Event: Consumes error, using a producer defined callback
consumeErrorAndFlush(Composable<?>) - Method in class reactor.core.composable.Composable: Forward any error or flush to the argument.
consumeEvent(Consumer<Event<T>>) - Method in class reactor.core.composable.Composable: Attach a Consumer to this Composable that will consume any values accepted by this Composable.
consumeFlush(Flushable<?>) - Method in interface reactor.core.action.Pipeline: Consume flush with the passed Flushable
consumeFlush(Flushable<?>) - Method in class reactor.core.composable.Composable
consumeFlush(Flushable<?>) - Method in class reactor.core.composable.Promise
consumeFlush(Flushable<?>) - Method in class reactor.core.composable.Stream
Consumer<T> - Interface in reactor.function: Implementations accept a given value and perform work on the argument.
consumer(Runnable) - Static method in class reactor.function.Functions: Wrap the given Runnable and compose a new Consumer.
ConsumerFilteringEventRouter - Class in reactor.event.routing: An EventRouter that filters consumers before routing events to them.
ConsumerFilteringEventRouter(Filter, ConsumerInvoker) - Constructor for class reactor.event.routing.ConsumerFilteringEventRouter: Creates a new ConsumerFilteringEventRouter that will use the filter to filter consumers.
consumerInvoker(ConsumerInvoker) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Assigns the component's Consumer Invoker
ConsumerInvoker - Interface in reactor.event.routing: Implementations of this interface are responsible for invoking a Consumer that may take into account automatic argument conversion, return values, and other situations that might be specific to a particular use-case.
consumerNotFoundHandler(Consumer<Object>) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the callback to invoke if a notification key is sent into this component and there are no consumers registered to respond to it.
consumerRegistry(Registry<Consumer<? extends Event<?>>>) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the Registry to use when creating this component.
consumerRegistry - Variable in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
contains(String) - Method in class reactor.event.Event.Headers: Determine whether the headers contain a value for the given name.
contains(Iterator, Object) - Static method in class reactor.util.CollectionUtils: Check whether the given Iterator contains the given element.
contains(Enumeration, Object) - Static method in class reactor.util.CollectionUtils: Check whether the given Enumeration contains the given element.
containsAny(Collection, Collection) - Static method in class reactor.util.CollectionUtils: Return true if any element in 'candidates' is contained in 'source'; otherwise returns false.
containsConstant(Enum<?>[], String) - Static method in class reactor.util.ObjectUtils: Check whether the given array of enum constants contains a constant with the given name, ignoring case when determining a match.
containsConstant(Enum<?>[], String, boolean) - Static method in class reactor.util.ObjectUtils: Check whether the given array of enum constants contains a constant with the given name.
containsElement(Object[], Object) - Static method in class reactor.util.ObjectUtils: Check whether the given array contains the given element.
containsInstance(Collection, Object) - Static method in class reactor.util.CollectionUtils: Check whether the given Collection contains the given element instance.
containsKey(Object) - Method in class reactor.util.LinkedCaseInsensitiveMap
containsKey(Object) - Method in class reactor.util.LinkedMultiValueMap
containsValue(Object) - Method in class reactor.util.LinkedMultiValueMap
containsWhitespace(CharSequence) - Static method in class reactor.util.StringUtils: Check whether the given CharSequence contains any whitespace characters.
containsWhitespace(String) - Static method in class reactor.util.StringUtils: Check whether the given String contains any whitespace characters.
ConversionFailedException - Exception in reactor.convert
convert(Object, Class<T>) - Method in interface reactor.convert.Converter: Convert the source to targetType.
convert(Object, Class<T>) - Method in class reactor.convert.DelegatingConverter
convert(Object, Class<T>) - Method in enum reactor.convert.StandardConverters.ConstructorParameterConverter
convert(Object, Class<T>) - Method in enum reactor.convert.StandardConverters.StringToNumberConverter
convert(Object, Class<T>) - Method in enum reactor.convert.StandardConverters.ToStringConverter
Converter - Interface in reactor.convert
CONVERTERS - Static variable in class reactor.convert.StandardConverters: A DelegatingConverter that will delegate to a StandardConverters.StringToNumberConverter, a StandardConverters.ConstructorParameterConverter and a StandardConverters.ToStringConverter in that order.
converters(Converter...) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's EventRouter to use the given {code converters}.
converters(List<Converter>) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's EventRouter to use the given {code converters}.
convertKey(String) - Method in class reactor.util.LinkedCaseInsensitiveMap: Convert the given key to a case-insensitive key.
copy(X) - Method in class reactor.core.Reactor.ReplyToEvent
copy() - Method in class reactor.event.Event: Create a copy of this event, reusing same headers, data and replyTo
copy(E) - Method in class reactor.event.Event: Create a copy of this event, reusing same headers and replyTo
copy(X) - Method in class reactor.event.support.CallbackEvent
copy() - Method in class reactor.io.Buffer: Create a new Buffer by copying the underlying ByteBuffer into a newly-allocated Buffer.
count(Stream<Long>) - Method in class reactor.core.composable.Stream: Count accepted events for each batch (every flush) and pass each accumulated long to the .
CountAction<T> - Class in reactor.core.action
CountAction(Observable, Object, Object) - Constructor for class reactor.core.action.CountAction
countOccurrencesOf(String, String) - Static method in class reactor.util.StringUtils: Count the occurrences of the substring in string s.
create(Class<T>) - Static method in class reactor.alloc.factory.Factories: Create a BatchFactorySupplier that supplies instances of the given type, which are created by invoked their no-arg constructor.
create(int, Class<T>) - Static method in class reactor.alloc.factory.Factories: Create a BatchFactorySupplier that supplies instances of the given type, which are created by invoked their no-arg constructor.
create() - Method in class reactor.core.dynamic.DynamicReactorFactory: Generate a Proxy based on the type used to create this factory.
create() - Static method in class reactor.util.UUIDUtils: Create a new time-based UUID.
createComposable(Environment, Observable, Tuple2<Selector, Object>) - Method in class reactor.core.composable.spec.ComposableSpec
createComposable(Environment, Observable, Tuple2<Selector, Object>) - Method in class reactor.core.composable.spec.DeferredPromiseSpec
createComposable(Environment, Observable, Tuple2<Selector, Object>) - Method in class reactor.core.composable.spec.DeferredStreamSpec
createComposable(Environment, Observable, Tuple2<Selector, Object>) - Method in class reactor.core.composable.spec.PromiseSpec
createComposable(Environment, Observable, Tuple2<Selector, Object>) - Method in class reactor.core.composable.spec.StreamSpec
createInputStream(InputStream) - Method in class reactor.io.encoding.compress.CompressionCodec
createInputStream(InputStream) - Method in class reactor.io.encoding.compress.GzipCodec
createInputStream(InputStream) - Method in class reactor.io.encoding.compress.SnappyCodec
createOutputStream(OutputStream) - Method in class reactor.io.encoding.compress.CompressionCodec
createOutputStream(OutputStream) - Method in class reactor.io.encoding.compress.GzipCodec
createOutputStream(OutputStream) - Method in class reactor.io.encoding.compress.SnappyCodec
createQueue() - Static method in class reactor.queue.BlockingQueueFactory: Creates a new BlockingQueue
createView() - Method in class reactor.io.Buffer: Create a Buffer.View of the current range of this Buffer.
createView(int, int) - Method in class reactor.io.Buffer: Create a Buffer.View of the given range of this Buffer.

D

dataBlockSize(int) - Method in class reactor.queue.spec.PersistentQueueSpec
dataBufferSize(int) - Method in class reactor.core.processor.spec.ProcessorSpec: How many data objects to pre-allocate in the buffer.
dataSupplier(Supplier<T>) - Method in class reactor.core.processor.spec.ProcessorSpec: Use the given Supplier to provide new instances of the data object for pre-allocation.
deallocate(T) - Method in class reactor.pool.LoadingPool: Deprecated.
deallocate(T) - Method in interface reactor.pool.Pool: Deprecated.

Returns an object to the pool.
debug() - Method in class reactor.core.composable.Composable: Print a debugged form of the root composable relative to this.
decode(String, String) - Static method in class reactor.function.support.UriUtils: Decodes the given encoded source String into an URI.
decoder(Consumer<byte[]>) - Method in class reactor.io.encoding.ByteArrayCodec
decoder(Consumer<IN>) - Method in interface reactor.io.encoding.Codec: Provide the caller with a decoder to turn a source object into an instance of the input type.
decoder(Consumer<IN>) - Method in class reactor.io.encoding.compress.CompressionCodec
decoder(Consumer<IN>) - Method in class reactor.io.encoding.DelimitedCodec
decoder(Consumer<Frame>) - Method in class reactor.io.encoding.FrameCodec
decoder(Consumer<T>) - Method in class reactor.io.encoding.JavaSerializationCodec
decoder(Consumer<IN>) - Method in class reactor.io.encoding.json.JsonCodec
decoder(Consumer<IN>) - Method in class reactor.io.encoding.LengthFieldCodec
decoder(Consumer<SRC>) - Method in class reactor.io.encoding.PassThroughCodec
decoder(Consumer<IN>) - Method in class reactor.io.encoding.SerializationCodec
decoder(Consumer<String>) - Method in class reactor.io.encoding.StringCodec
decrement() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Decrement an amount of runs Registration has to run until it's elapsed
DEFAULT_WHEEL_SIZE - Static variable in class reactor.timer.HashWheelTimer
defaultDispatcher() - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the component to use the configured Environment's default dispatcher
DefaultEnvironmentSupplier - Class in reactor.core.support: A default implementation of a Supplier that provides a singleton .Environment which is created in the constructor.
DefaultEnvironmentSupplier() - Constructor for class reactor.core.support.DefaultEnvironmentSupplier
defaultEventAllocator() - Static method in class reactor.event.alloc.EventAllocator: Default Event Allocator, uses ReferenceCountingAllocator for allocating and recycling events.
defer(Environment) - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise.
defer(Environment, String) - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise.
defer(Environment, Dispatcher) - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise.
defer() - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise.
defer(Environment) - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream, ready to accept values.
defer(Environment, String) - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream, ready to accept values.
defer(Environment, Dispatcher) - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream, ready to accept values.
defer() - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream, ready to accept values.
defer(T) - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream that will implicitly Deferred.accept(Object) the given value whenever the Stream.flush() function is invoked.
defer(Supplier<T>) - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream that will implicitly Deferred.accept(Object) the supplied value whenever the Stream.flush() function is invoked.
defer(Iterable<T>) - Static method in class reactor.core.composable.spec.Streams: Build a deferred Stream that will implicitly Deferred.accept(Object) the given values whenever the Stream.flush() function is invoked.
Deferred<T,C extends Composable<T>> - Class in reactor.core.composable: A Deferred is used to provide a separate between supplying values and consuming values.
Deferred(C) - Constructor for class reactor.core.composable.Deferred: Creates a new Deferred using the given Composable
Deferred(C, C) - Constructor for class reactor.core.composable.Deferred: Creates a new Deferred using decoupled given head and tail Composable
DeferredPromiseSpec<T> - Class in reactor.core.composable.spec: A helper class for specifying a Deferred Promise.
DeferredPromiseSpec() - Constructor for class reactor.core.composable.spec.DeferredPromiseSpec
DeferredStreamSpec<T> - Class in reactor.core.composable.spec: A helper class for specifying a Deferred Stream.
DeferredStreamSpec() - Constructor for class reactor.core.composable.spec.DeferredStreamSpec
DelegatingConsumer<T> - Class in reactor.function.support: An implementation of Consumer that maintains a list of delegates to which events received by this Consumer will be passed along.
DelegatingConsumer() - Constructor for class reactor.function.support.DelegatingConsumer
DelegatingConverter - Class in reactor.convert: A converter that delegates to one or more converters.
DelegatingConverter(List<Converter>) - Constructor for class reactor.convert.DelegatingConverter: Creates a new DelegatingConverter that will delegate to the given list of delegateConverters.
DelegatingConverter(Converter...) - Constructor for class reactor.convert.DelegatingConverter: Creates a new DelegatingConverter that will delegate to the given list of delegateConverters.
delete(String, String) - Static method in class reactor.util.StringUtils: Delete all occurrences of the given substring.
deleteAny(String, String) - Static method in class reactor.util.StringUtils: Delete any character in a given String.
deleteOnExit(boolean) - Method in class reactor.queue.spec.PersistentQueueSpec
DelimitedCodec<IN,OUT> - Class in reactor.io.encoding: 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.
DelimitedCodec(Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.DelimitedCodec: Create a line-feed-delimited codec, using the given Codec as a delegate.
DelimitedCodec(boolean, Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.DelimitedCodec: Create a line-feed-delimited codec, using the given Codec as a delegate.
DelimitedCodec(byte, boolean, Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.DelimitedCodec: Create a delimited codec using the given delimiter and using the given Codec as a delegate.
delimitedListToStringArray(String, String) - Static method in class reactor.util.StringUtils: Take a String which is a delimited list and convert it to a String array.
delimitedListToStringArray(String, String, String) - Static method in class reactor.util.StringUtils: Take a String which is a delimited list and convert it to a String array.
deserializer(ObjectMapper, Class<IN>, Consumer<IN>) - Method in class reactor.io.encoding.json.JacksonJsonCodec
deserializer(Kryo, Class<IN>, Consumer<IN>) - Method in class reactor.io.encoding.kryo.KryoCodec
deserializer(Map<Class<?>, Message>, Class<IN>, Consumer<IN>) - Method in class reactor.io.encoding.protobuf.ProtobufCodec
deserializer(E, Class<IN>, Consumer<IN>) - Method in class reactor.io.encoding.SerializationCodec
dispatch(E, EventRouter, Consumer<E>, Consumer<Throwable>) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
dispatch(Object, E, Registry<Consumer<? extends Event<?>>>, Consumer<Throwable>, EventRouter, Consumer<E>) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
dispatch(Object, E, Registry<Consumer<? extends Event<?>>>, Consumer<Throwable>, EventRouter, Consumer<E>) - Method in class reactor.event.dispatch.ActorDispatcher
dispatch(E, EventRouter, Consumer<E>, Consumer<Throwable>) - Method in class reactor.event.dispatch.ActorDispatcher
dispatch(Object, E, Registry<Consumer<? extends Event<?>>>, Consumer<Throwable>, EventRouter, Consumer<E>) - Method in interface reactor.event.dispatch.Dispatcher: Instruct the Dispatcher to dispatch the event that has the given key.
dispatch(E, EventRouter, Consumer<E>, Consumer<Throwable>) - Method in interface reactor.event.dispatch.Dispatcher: Instruct the Dispatcher to dispatch the given Event using the given Consumer.
dispatch(E, EventRouter, Consumer<E>, Consumer<Throwable>) - Method in class reactor.event.dispatch.SynchronousDispatcher
dispatch(Object, E, Registry<Consumer<? extends Event<?>>>, Consumer<Throwable>, EventRouter, Consumer<E>) - Method in class reactor.event.dispatch.SynchronousDispatcher
dispatch(Object, E, Registry<Consumer<? extends Event<?>>>, Consumer<Throwable>, EventRouter, Consumer<E>) - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
dispatch(E, EventRouter, Consumer<E>, Consumer<Throwable>) - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
Dispatcher - Annotation Type in reactor.core.dynamic.annotation: Used on a to specify the Dispatcher that should be used by the underlying Reactor.
dispatcher(Dispatcher) - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the component to use the given dispatcher
dispatcher(String) - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the component to the dispatcher in the configured Environment with the given dispatcherName
Dispatcher - Interface in reactor.event.dispatch: A Dispatcher is used to dispatch Events to Consumers.
DispatcherComponentSpec<SPEC extends DispatcherComponentSpec<SPEC,TARGET>,TARGET> - Class in reactor.core.spec.support: A generic environment-aware class for specifying components that need to be configured with an Environment and Dispatcher.
DispatcherComponentSpec() - Constructor for class reactor.core.spec.support.DispatcherComponentSpec
DispatcherConfiguration - Class in reactor.core.configuration: An encapsulation of the configuration for a Dispatcher.
DispatcherConfiguration(String, DispatcherType, Integer, Integer) - Constructor for class reactor.core.configuration.DispatcherConfiguration
dispatchErrorHandler(Consumer<Throwable>) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's error handler for any errors occurring during dispatch (e.g.
DispatcherType - Enum in reactor.core.configuration: An enumeration of supported types of Dispatcher.
distinct() - Method in class reactor.core.composable.Stream: Create a new Stream that filters out consecutive equals values.
DistinctAction<T> - Class in reactor.core.action
DistinctAction(Observable, Object, Object) - Constructor for class reactor.core.action.DistinctAction
doAccept(Event<T>) - Method in class reactor.core.action.Action
doAccept(Event<T>) - Method in class reactor.core.action.BatchAction
doAccept(Event<T>) - Method in class reactor.core.action.CallbackAction
doAccept(Event<T>) - Method in class reactor.core.action.CallbackEventAction
doAccept(Event<T>) - Method in class reactor.core.action.ConnectAction
doAccept(Event<T>) - Method in class reactor.core.action.CountAction
doAccept(Event<T>) - Method in class reactor.core.action.DistinctAction
doAccept(Event<T>) - Method in class reactor.core.action.FilterAction
doAccept(Event<Object>) - Method in class reactor.core.action.FlushableAction
doAccept(Event<Iterable<T>>) - Method in class reactor.core.action.ForEachAction
doAccept(Event<T>) - Method in class reactor.core.action.MapAction
doAccept(Event<T>) - Method in class reactor.core.action.MapManyAction
doAccept(Event<T>) - Method in class reactor.core.action.MovingWindowAction
doAccept(Event<T>) - Method in class reactor.core.action.ScanAction
doAccept(Event<Object>) - Method in class reactor.core.action.SupplyAction
doAccept(Event<T>) - Method in class reactor.core.action.TimeoutAction
doAccept(Event<T>) - Method in class reactor.core.action.WhenAction
doAccept(Event<T>) - Method in class reactor.core.action.WindowAction
doAccept(T) - Method in class reactor.function.support.SingleUseConsumer
doesNotContain(String, String, String) - Static method in class reactor.util.Assert: Assert that the given text does not contain the given substring.
doesNotContain(String, String) - Static method in class reactor.util.Assert: Assert that the given text does not contain the given substring.
doFilter(List<T>, Object) - Method in class reactor.filter.FirstFilter
doFilter(List<T>, Object) - Method in class reactor.filter.PassThroughFilter
doFilter(List<T>, Object) - Method in class reactor.filter.RandomFilter
doFilter(List<T>, Object) - Method in class reactor.filter.RoundRobinFilter
doFirst(Event<T>) - Method in class reactor.core.action.BatchAction
doFlush(Event<T>) - Method in class reactor.core.action.BatchAction
doFlush(Event<T>) - Method in class reactor.core.action.BufferAction
doFlush(Event<T>) - Method in class reactor.core.action.CollectAction
doFlush(Event<T>) - Method in class reactor.core.action.ReduceAction
doNext(Event<T>) - Method in class reactor.core.action.BatchAction
doNext(Event<T>) - Method in class reactor.core.action.BufferAction
doNext(Event<T>) - Method in class reactor.core.action.CollectAction
doNext(Event<T>) - Method in class reactor.core.action.ReduceAction
doubleValue() - Method in class reactor.alloc.RecyclableNumber
doWindow(Long) - Method in class reactor.core.action.MovingWindowAction
doWindow(Long) - Method in class reactor.core.action.WindowAction
drain(Iterable<T>) - Static method in class reactor.function.Suppliers: Create a Supplier which drains the contents of the given Iterable by internally creating an Iterator and delegating each call of Supplier.get() to Iterator.next().
drainAll(Iterable<Iterable<T>>) - Static method in class reactor.function.Suppliers: Create a Supplier which drains all of the given Iterables.
duplicate() - Method in class reactor.io.Buffer: Create a new Buffer by calling ByteBuffer.duplicate() on the underlying ByteBuffer.
DynamicReactor - Interface in reactor.core.dynamic: A DynamicReactor is an arbitrary interface that a proxy generator can use to wire calls to the interface to appropriate Reactor.on(reactor.event.selector.Selector, reactor.function.Consumer) and Reactor.notify(Object, reactor.event.Event) calls.
DynamicReactorFactory<T extends DynamicReactor> - Class in reactor.core.dynamic: A DynamicReactorFactory is responsible for generating a Proxy based on the given interface, that intercepts calls to the interface and translates them into the appropriate Reactor.on(reactor.event.selector.Selector, reactor.function.Consumer) or Reactor.notify(Object, Event) calls.
DynamicReactorFactory(Environment, Class<T>) - Constructor for class reactor.core.dynamic.DynamicReactorFactory: Creates a new DynamicReactorFactory that will use the given env when creating its Reactor.
DynamicReactorFactory(Environment, Class<T>, List<MethodSelectorResolver>, List<MethodNotificationKeyResolver>, ConsumerInvoker, Converter) - Constructor for class reactor.core.dynamic.DynamicReactorFactory: Creates a new DynamicReactorFactory that will use the given env when creating its Reactor.

E

each(Iterable<T>) - Method in class reactor.core.composable.spec.StreamSpec: Configures the stream to contain the given values.
encodeFragment(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI fragment.
encodeHost(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI host.
encodeHttpUrl(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given HTTP URI into an encoded String.
encodePath(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI path.
encodePathSegment(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI path segment.
encodePort(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI port.
encodeQuery(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI query.
encodeQueryParam(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI query parameter.
encoder() - Method in class reactor.io.encoding.ByteArrayCodec
encoder() - Method in interface reactor.io.encoding.Codec: Provide the caller with an encoder to turn an output object into an instance of the source type.
encoder() - Method in class reactor.io.encoding.compress.CompressionCodec
encoder() - Method in class reactor.io.encoding.DelimitedCodec
encoder() - Method in class reactor.io.encoding.FrameCodec
encoder() - Method in class reactor.io.encoding.JavaSerializationCodec
encoder() - Method in class reactor.io.encoding.json.JsonCodec
encoder() - Method in class reactor.io.encoding.LengthFieldCodec
encoder() - Method in class reactor.io.encoding.PassThroughCodec
encoder() - Method in class reactor.io.encoding.SerializationCodec
encoder() - Method in class reactor.io.encoding.StringCodec
encodeScheme(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI scheme.
encodeUri(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given source URI into an encoded String.
encodeUriComponents(String, String, String, String, String, String, String, String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given source URI components into an encoded String.
encodeUserInfo(String, String) - Static method in class reactor.function.support.UriUtils: Encodes the given URI user info.
end() - Method in interface reactor.function.batch.BatchConsumer: Called when a batch ends.
end() - Method in class reactor.function.support.DelegatingConsumer
END_EVENT - Static variable in class reactor.core.composable.Composable
endsWithIgnoreCase(String, String) - Static method in class reactor.util.StringUtils: Test if the given String ends with the specified suffix, ignoring upper/lower case.
entries - Variable in class reactor.tuple.Tuple
entrySet() - Method in class reactor.util.LinkedMultiValueMap
env(Environment) - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the spec, and potentially the component being configured, to use the given environment
Environment - Class in reactor.core
Environment() - Constructor for class reactor.core.Environment: Creates a new Environment that will use a PropertiesConfigurationReader to obtain its initial configuration.
Environment(ConfigurationReader) - Constructor for class reactor.core.Environment: Creates a new Environment that will use the given configurationReader to obtain its initial configuration.
Environment(Map<String, List<Dispatcher>>, ConfigurationReader) - Constructor for class reactor.core.Environment: Creates a new Environment that will contain the given dispatchers, will use the given configurationReader to obtain additional configuration.
equals(Object) - Method in class reactor.core.Reactor
equals(Object) - Method in class reactor.tuple.Tuple
equals(Object) - Method in class reactor.util.LinkedMultiValueMap
error(Throwable) - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise and use the given error to complete the Promise immediately.
error(Throwable) - Method in class reactor.core.composable.spec.PromiseSpec: Configures the promise to have been completed with the given error.
errorAccepted(Throwable) - Method in class reactor.core.composable.Promise
errorConsumer - Variable in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
errorHandler(Consumer<Throwable>) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: The Consumer to be invoked when an error occurs.
event - Variable in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
Event<T> - Class in reactor.event: Wrapper for an object that needs to be processed by Consumers.
Event(Class<T>) - Constructor for class reactor.event.Event: Creates a new Event based on the type T of
Event(Event.Headers, T) - Constructor for class reactor.event.Event: Creates a new Event with the given headers and data.
Event(Event.Headers, T, Consumer<Throwable>) - Constructor for class reactor.event.Event: Creates a new Event with the given headers, data and reactor.function.Consumer.
Event(T) - Constructor for class reactor.event.Event: Creates a new Event with the given data.
Event.Headers - Class in reactor.event: Headers are a Map-like structure of name-value pairs.
EVENT_LOOP - Static variable in class reactor.core.Environment: The name of the default event loop dispatcher
EventAllocator - Class in reactor.event.alloc: Generic Event Allocator.
EventAllocator() - Constructor for class reactor.event.alloc.EventAllocator
EventAllocator(Class[]) - Constructor for class reactor.event.alloc.EventAllocator: Create a new EventAllocator, containing pre-created Allocators for given es.
EventConsumer<T> - Class in reactor.event.support: Simple Consumer implementation that pulls the data from an Event and passes it to a delegate Consumer.
EventConsumer(Consumer<T>) - Constructor for class reactor.event.support.EventConsumer: Creates a new EventConsumer that will pass event data to the given delegate.
EventFactorySupplier<T> - Class in reactor.alloc.factory: A Supplier implementation that instantiates Events based on Event data type.
EventFactorySupplier(Class<T>) - Constructor for class reactor.alloc.factory.EventFactorySupplier
eventFilter(Filter) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Assigns the component's Filter
eventHandler(Consumer<Reference<T>>) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: The Consumer to be invoked with a sequence ID is published.
EventLoopDispatcher - Class in reactor.event.dispatch: Deprecated.
EventLoopDispatcher(String, int) - Constructor for class reactor.event.dispatch.EventLoopDispatcher: Deprecated.

Creates a new EventLoopDispatcher with the given name and backlog.
EventLoopDispatcher(String, int, Consumer<Throwable>) - Constructor for class reactor.event.dispatch.EventLoopDispatcher: Deprecated.

Creates a new EventLoopDispatcher with the given name and backlog.
eventRouter(EventRouter) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Assigns the component's EventRouter
eventRouter - Variable in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
EventRouter - Interface in reactor.event.routing: An EventRouter is used to route an Event to Consumers.
EventRoutingComponentSpec<SPEC extends EventRoutingComponentSpec<SPEC,TARGET>,TARGET> - Class in reactor.core.spec.support: A generic environment-aware class for specifying components that need to be configured with an Environment, Dispatcher, and EventRouter.
EventRoutingComponentSpec() - Constructor for class reactor.core.spec.support.EventRoutingComponentSpec
EventRoutingComponentSpec.EventRoutingStrategy - Enum in reactor.core.spec.support
eventThreads(int) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: Specify the number of threads the underlying RingBuffer will use.
execute(Runnable) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
execute(AbstractLifecycleDispatcher.Task) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
execute(Runnable) - Method in class reactor.event.dispatch.ActorDispatcher
execute(AbstractLifecycleDispatcher.Task) - Method in class reactor.event.dispatch.RingBufferDispatcher
execute(Runnable) - Method in class reactor.event.dispatch.SynchronousDispatcher
execute(AbstractLifecycleDispatcher.Task) - Method in class reactor.event.dispatch.ThreadPoolExecutorDispatcher
execute(Runnable) - Method in class reactor.event.dispatch.ThreadPoolExecutorDispatcher
execute(Runnable) - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
execute(AbstractLifecycleDispatcher.Task) - Method in class reactor.event.dispatch.WorkQueueDispatcher
executor(ExecutorService) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: The ExecutorService to use inside the RingBuffer.
expandTailRecursionPile(int) - Method in class reactor.event.dispatch.AbstractSingleThreadDispatcher

F

Factories - Class in reactor.alloc.factory: Helper class for creating object factories.
Factories() - Constructor for class reactor.alloc.factory.Factories
fill() - Method in class reactor.alloc.factory.BatchFactorySupplier
fillInStackTrace() - Method in exception reactor.function.support.CancelConsumerException
filter(Function<T, Boolean>) - Method in class reactor.core.composable.Composable: Evaluate each accepted value against the given predicate Function.
filter() - Method in class reactor.core.composable.Composable: Evaluate each accepted boolean value.
filter(Composable<Boolean>) - Method in class reactor.core.composable.Composable: Evaluate each accepted boolean value.
filter(Predicate<T>) - Method in class reactor.core.composable.Composable: Evaluate each accepted value against the given Predicate.
filter(Predicate<T>, Composable<T>) - Method in class reactor.core.composable.Composable: Evaluate each accepted value against the given Predicate.
filter(Predicate<T>) - Method in class reactor.core.composable.Promise
filter(Predicate<T>, Composable<T>) - Method in class reactor.core.composable.Promise
filter() - Method in class reactor.core.composable.Promise
filter(Composable<Boolean>) - Method in class reactor.core.composable.Promise
filter(Function<T, Boolean>) - Method in class reactor.core.composable.Promise
filter() - Method in class reactor.core.composable.Stream
filter(Composable<Boolean>) - Method in class reactor.core.composable.Stream
filter(Function<T, Boolean>) - Method in class reactor.core.composable.Stream
filter(Predicate<T>) - Method in class reactor.core.composable.Stream
filter(Predicate<T>, Composable<T>) - Method in class reactor.core.composable.Stream
Filter - Interface in reactor.filter: A Filter is used to filter a list of items.
filter(List<T>, Object) - Method in interface reactor.filter.Filter: Filters the given List of items.
filter(List<T>, Object) - Method in class reactor.filter.TraceableDelegatingFilter
filter(Iterable<T>, Predicate<T>) - Static method in class reactor.function.Suppliers: Filter the given Iterable using the given Predicate so that calls to the return Supplier.get() will provide only items from the original collection which pass the predicate test.
FilterAction<T> - Class in reactor.core.action
FilterAction(Predicate<T>, Observable, Object, Object, Observable, Object) - Constructor for class reactor.core.action.FilterAction
find(Method, Class<A>) - Static method in class reactor.core.dynamic.reflect.support.AnnotationUtils: Finds the annotation of the given type on the given method.
findCommonElementType(Collection) - Static method in class reactor.util.CollectionUtils: Find the common element type of the given Collection, if any.
findFirstMatch(Collection, Collection) - Static method in class reactor.util.CollectionUtils: Return the first element in 'candidates' that is contained in 'source'.
findValueOfType(Collection<?>, Class<T>) - Static method in class reactor.util.CollectionUtils: Find a single value of the given type in the given Collection.
findValueOfType(Collection<?>, Class<?>[]) - Static method in class reactor.util.CollectionUtils: Find a single value of one of the given types in the given Collection: searching the Collection for a value of the first type, then searching for a value of the second type, etc.
first() - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be only the first value of each batch.
first(int) - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be only the first value of each batch.
first() - Method in class reactor.io.Buffer: Get the first byte from this Buffer.
firstEventRouting() - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's EventRouter to route events to the first of the matching consumers
FirstFilter - Class in reactor.filter: A Filter implementation that returns the first item.
FirstFilter() - Constructor for class reactor.filter.FirstFilter
flip() - Method in class reactor.io.Buffer: Flip this Buffer.
floatValue() - Method in class reactor.alloc.RecyclableNumber
flush() - Method in class reactor.core.action.BufferAction
flush() - Method in class reactor.core.action.CollectAction
flush() - Method in class reactor.core.action.ConnectAction
flush() - Method in class reactor.core.action.CountAction
flush() - Method in interface reactor.core.action.Flushable: Trigger flush on this component, generally draining any collected values.
flush() - Method in class reactor.core.action.ForEachAction
flush() - Method in class reactor.core.action.ReduceAction
flush() - Method in class reactor.core.action.SupplyAction
flush() - Method in class reactor.core.action.WindowAction
flush() - Method in class reactor.core.composable.Composable: Flush any cached or unprocessed values through this Stream.
flush() - Method in class reactor.core.composable.Deferred: Flush the Composable such that it can trigger batch operations.
flush() - Method in class reactor.core.composable.Promise
flush() - Method in class reactor.core.composable.Stream
FLUSH_EVENT - Static variable in interface reactor.core.action.Flushable
Flushable<T> - Interface in reactor.core.action: Component that can be flushed
FlushableAction - Class in reactor.core.action
FlushableAction(Flushable<?>, Observable, Object) - Constructor for class reactor.core.action.FlushableAction
flushWhen(Predicate<T>) - Method in class reactor.core.composable.Stream: Consume values and trigger flush when matches.
Fn - Class in reactor.function: Alias for Functions
Fn() - Constructor for class reactor.function.Fn
FOREACH_FLUSH - Static variable in class reactor.core.action.ForEachAction
ForEachAction<T> - Class in reactor.core.action
ForEachAction(Observable, Object, Object, Object) - Constructor for class reactor.core.action.ForEachAction
ForEachAction(Iterable<T>, Observable, Object, Object, Object) - Constructor for class reactor.core.action.ForEachAction
fork() - Method in class reactor.core.fork.ForkJoinPool: Asynchronously execute tasks added to the returned ForkJoinTask and publish the non-null results, one per task, to the Stream returned from ForkJoinTask.compose().
ForkJoinPool - Class in reactor.core.fork: Simple Executor backed fork/join pool that will coalesce results from asynchronous tasks and publish them into a Promise or a Stream depending on whether you intend to fork() an execution or join() them together.
ForkJoinPool(Environment) - Constructor for class reactor.core.fork.ForkJoinPool
ForkJoinPool(Environment, Dispatcher, Executor) - Constructor for class reactor.core.fork.ForkJoinPool
ForkJoinTask<T,C extends Composable<T>> - Class in reactor.core.fork: Represents a collection of asynchronous tasks that will be executed once per ForkJoinTask.submit().
Frame - Class in reactor.io.encoding
Frame(Buffer, Buffer) - Constructor for class reactor.io.encoding.Frame
FrameCodec - Class in reactor.io.encoding: Codec for decoding data into length-field-based Frames.
FrameCodec(int, FrameCodec.LengthField) - Constructor for class reactor.io.encoding.FrameCodec
FrameCodec.LengthField - Enum in reactor.io.encoding
fromGenericType(Class<T>) - Static method in class reactor.util.TypeUtils
fromTypeRef(TypeReference<T>) - Static method in class reactor.util.TypeUtils
Function<T,R> - Interface in reactor.function: Implementations of this class perform work on the given parameter and return a result of an optionally different type.
function(Callable<V>) - Static method in class reactor.function.Functions: Wrap the given Callable and compose a new Function.
Functions - Class in reactor.function: Helper methods to provide syntax sugar for working with functional components in Reactor.
Functions() - Constructor for class reactor.function.Functions

G

generate(Supplier<T>) - Method in class reactor.core.composable.spec.StreamSpec: Configures the stream to pass value from a Supplier on flush.
get() - Method in class reactor.alloc.AbstractReference
get() - Method in class reactor.alloc.factory.BatchFactorySupplier
get() - Method in class reactor.alloc.factory.EventFactorySupplier
get() - Method in class reactor.alloc.factory.NoArgConstructorFactory
get() - Method in class reactor.alloc.spec.RingBufferAllocatorSpec
get() - Method in class reactor.core.composable.Promise: Returns the value that completed this promise.
get() - Method in class reactor.core.processor.Operation: Get the Operation payload.
get() - Method in class reactor.core.processor.Processor
get() - Method in class reactor.core.processor.spec.ProcessorSpec
get() - Method in class reactor.core.spec.support.DispatcherComponentSpec
get() - Method in class reactor.core.support.DefaultEnvironmentSupplier
get(Class<T>) - Method in class reactor.event.alloc.EventAllocator: Allocate an object from the internal pool, based on the type of Event.
get(String) - Method in class reactor.event.Event.Headers: Get the value for the given header.
get() - Method in interface reactor.function.Supplier: Get an object.
get() - Method in class reactor.function.support.Tap: Get the value of this Tap, which is the current value of the event stream this tap is consuming.
get() - Method in class reactor.io.Buffer.View
get() - Method in class reactor.queue.IndexedChronicleQueuePersistor
get() - Method in class reactor.queue.InMemoryQueuePersistor
get() - Method in interface reactor.queue.QueuePersistor: Returns a Function that will return the item with the given id.
get() - Method in class reactor.queue.spec.PersistentQueueSpec
get(int) - Method in class reactor.tuple.Tuple: Get the object at the given index.
get(Object) - Method in class reactor.util.LinkedCaseInsensitiveMap
get(Object) - Method in class reactor.util.LinkedMultiValueMap
get() - Method in class reactor.util.PartitionedReferencePile
getAcceptCount() - Method in class reactor.core.action.BatchAction
getAcceptKey() - Method in class reactor.core.composable.Composable: Get the anonymous Selector and notification key for doing accepts.
getAcceptSelector() - Method in class reactor.core.composable.Composable: Get the anonymous Selector and notification key for doing accepts.
getAdditionalProperties() - Method in class reactor.core.configuration.ReactorConfiguration: Additional configuration properties.
getAge() - Method in class reactor.alloc.AbstractReference
getAge() - Method in interface reactor.alloc.Reference: Get the age of this Reference since it's creation.
getBacklog() - Method in class reactor.core.configuration.DispatcherConfiguration: Returns the configured backlog, or null if the backlog was not configured
getBacklog() - Method in class reactor.event.dispatch.AbstractMultiThreadDispatcher
getBacklog() - Method in class reactor.event.dispatch.AbstractSingleThreadDispatcher
getBatchSize() - Method in class reactor.core.action.BatchAction
getConsumerInvoker() - Method in class reactor.core.dynamic.DynamicReactorFactory: Get the ConsumerInvoker to use when invoking Consumers.
getConsumerInvoker() - Method in class reactor.event.routing.ConsumerFilteringEventRouter: Returns the ConsumerInvoker being used by the event router
getConsumerRegistry() - Method in class reactor.core.Reactor: Get the Registry is use to maintain the Consumers currently listening for events on this Reactor.
getContext() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
getConverter() - Method in class reactor.core.dynamic.DynamicReactorFactory: Get the Converter to use when coercing arguments.
getData() - Method in class reactor.event.Event: Get the internal data being wrapped.
getData() - Method in class reactor.io.encoding.Frame
getDefaultDispatcher() - Method in class reactor.core.Environment: Returns the default dispatcher for this environment.
getDefaultDispatcherName() - Method in class reactor.core.configuration.ReactorConfiguration: Returns the name of the default dispatcher.
getDelegate() - Method in class reactor.core.Reactor.ReplyToConsumer
getDispatcher(String) - Method in class reactor.core.Environment: Returns the dispatcher with the given name.
getDispatcher() - Method in class reactor.core.Reactor: Get the Dispatcher currently in use.
getDispatcherConfigurations() - Method in class reactor.core.configuration.ReactorConfiguration: Returns a List of DispatcherConfigurations.
getDispatchErrorHandler() - Method in class reactor.core.Reactor
getDisplayString(Object) - Static method in class reactor.util.ObjectUtils: Return a content-based String representation if obj is not null; otherwise returns an empty String.
getElseObservable() - Method in class reactor.core.action.FilterAction
getElseSuccess() - Method in class reactor.core.action.FilterAction
getEnd() - Method in class reactor.io.Buffer.View: Get the end of this range.
getEngine() - Method in class reactor.io.encoding.SerializationCodec
getEnvironment() - Method in class reactor.core.composable.Composable: Get the assigned Environment.
getError() - Method in class reactor.core.composable.Composable: Get the anonymous Selector and notification key for doing errors.
getErrorConsumer() - Method in class reactor.event.Event: Get the internal error consumer callback being wrapped.
getErrorCount() - Method in class reactor.core.action.BatchAction
getEventRouter() - Method in class reactor.core.Reactor: Get the EventRouter used to route events to Consumers.
getFailureKey() - Method in class reactor.core.action.Action
getFilename(String) - Static method in class reactor.util.StringUtils: Extract the filename from the given path, e.g.
getFilenameExtension(String) - Static method in class reactor.util.StringUtils: Extract the filename extension from the given path, e.g.
getFilter() - Method in class reactor.event.routing.ConsumerFilteringEventRouter: Returns the Filter being used
getFirst(K) - Method in class reactor.util.LinkedMultiValueMap
getFirst(K) - Method in interface reactor.util.MultiValueMap: Return the first value for the given key.
getFirstKey() - Method in class reactor.core.action.BatchAction
getFlush() - Method in class reactor.core.composable.Composable: Get the anonymous flush Selector for batch consuming.
getFlushable() - Method in class reactor.core.action.FlushableAction
getFlushKey() - Method in class reactor.core.action.BatchAction
getHeaderResolver() - Method in class reactor.event.selector.MatchAllSelector
getHeaderResolver() - Method in class reactor.event.selector.ObjectSelector
getHeaderResolver() - Method in class reactor.event.selector.RegexSelector
getHeaderResolver() - Method in interface reactor.event.selector.Selector: Return a component that can resolve headers from a key
getHeaderResolver() - Method in class reactor.event.selector.SetMembershipSelector
getHeaderResolver() - Method in class reactor.event.selector.UriPathSelector
getHeaderResolver() - Method in class reactor.event.selector.UriSelector
getHeaders() - Method in class reactor.event.Event: Get the Event.Headers attached to this event.
getId() - Method in class reactor.core.Reactor: Get the unique, time-used UUID of this Reactor.
getId() - Method in class reactor.event.Event: Get the globally-unique id of this event.
getId() - Method in interface reactor.support.Identifiable
getIdentityHexString(Object) - Static method in class reactor.util.ObjectUtils: Return a hex String form of an object's identity hash code.
getKey() - Method in class reactor.event.Event: Get the key this event was notified on.
getName() - Method in class reactor.core.configuration.DispatcherConfiguration: Returns the name of the Dispatcher.
getObject() - Method in class reactor.event.registry.CachableRegistration
getObject() - Method in interface reactor.event.registry.Registration: The object that was registered
getObject() - Method in class reactor.event.selector.MatchAllSelector
getObject() - Method in class reactor.event.selector.ObjectSelector
getObject() - Method in interface reactor.event.selector.Selector: Get the object being used for comparisons and equals checks.
getObject() - Method in class reactor.event.selector.SetMembershipSelector
getObject() - Method in class reactor.timer.HashWheelTimer.TimerRegistration
getObservable() - Method in class reactor.core.action.Action
getObservable() - Method in class reactor.core.composable.Composable: Get the current Observable.
getOrigin() - Method in class reactor.event.Event.Headers: Get the origin header
getParent() - Method in class reactor.core.composable.Composable: Get the parent Composable for callback callback.
getPrefix() - Method in class reactor.io.encoding.Frame
getProperty(String, String) - Method in class reactor.core.Environment: Gets the property with the given key.
getProperty(String, Class<T>, T) - Method in class reactor.core.Environment: Gets the property with the given key, converting it to the required type using the standard converters.
getReferenceCount() - Method in class reactor.alloc.AbstractReference
getReferenceCount() - Method in interface reactor.alloc.Reference: Get the current number of references retained to this object.
getReplyTo() - Method in class reactor.event.Event: Get the key to send replies to.
getReplyToObservable() - Method in class reactor.core.Reactor.ReplyToEvent
getResolution() - Method in class reactor.timer.HashWheelTimer
getResolution() - Method in class reactor.timer.SimpleHashWheelTimer
getResolution() - Method in interface reactor.timer.Timer: Get the resolution of this tTimer.
getRootReactor() - Method in class reactor.core.Environment: Returns this environments root Reactor, creating it if necessary.
getRootTimer() - Method in class reactor.core.Environment: Get the Environment-wide SimpleHashWheelTimer.
getSelector() - Method in class reactor.event.registry.CachableRegistration
getSelector() - Method in interface reactor.event.registry.Registration: The Selector that was used when the registration was made.
getSelector() - Method in class reactor.timer.HashWheelTimer.TimerRegistration
getSelectorResolvers() - Method in class reactor.core.dynamic.DynamicReactorFactory: Get the list of MethodSelectorResolvers in use.
getSize() - Method in class reactor.core.configuration.DispatcherConfiguration: Returns the configured size, or null if the size was not configured
getSourceType() - Method in exception reactor.convert.ConversionFailedException: Returns the type that could not be converted from
getStart() - Method in class reactor.io.Buffer.View: Get the start of this range.
getSuccessKey() - Method in class reactor.core.action.Action
getT1() - Method in class reactor.tuple.Tuple1: Type-safe way to get the first object of this Tuple.
getT2() - Method in class reactor.tuple.Tuple2: Type-safe way to get the second object of this Tuple.
getT3() - Method in class reactor.tuple.Tuple3: Type-safe way to get the third object of this Tuple.
getT4() - Method in class reactor.tuple.Tuple4: Type-safe way to get the fourth object of this Tuple.
getT5() - Method in class reactor.tuple.Tuple5: Type-safe way to get the fifth object of this Tuple.
getT6() - Method in class reactor.tuple.Tuple6: Type-safe way to get the sixth object of this Tuple.
getT7() - Method in class reactor.tuple.Tuple7: Type-safe way to get the seventh object of this Tuple.
getT8() - Method in class reactor.tuple.Tuple8: Type-safe way to get the eighth object of this Tuple.
getTargetType() - Method in exception reactor.convert.ConversionFailedException: Returns the type that could not be converted to
getTasks() - Method in class reactor.core.fork.ForkJoinTask: Get the MutableList of tasks that will be submitted when ForkJoinTask.submit(Object) is called.
getTimer() - Static method in class reactor.timer.TimeUtils
getTRest() - Method in class reactor.tuple.TupleN: Type-safe way to get the remaining objects of this Tuple.
getType() - Method in class reactor.core.configuration.DispatcherConfiguration: Returns the type of the Dispatcher.
getUncaughtErrorHandler() - Method in class reactor.core.Reactor
GzipCodec<IN,OUT> - Class in reactor.io.encoding.compress
GzipCodec(Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.compress.GzipCodec

H

halt() - Method in class reactor.alloc.RingBufferAllocator
halt() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
halt() - Method in class reactor.event.dispatch.ActorDispatcher
halt() - Method in interface reactor.event.dispatch.Dispatcher: Shutdown this Dispatcher, forcibly halting any tasks currently executing and discarding any tasks that have not yet been exected.
halt() - Method in class reactor.event.dispatch.RingBufferDispatcher
halt() - Method in class reactor.event.dispatch.SynchronousDispatcher
halt() - Method in class reactor.event.dispatch.ThreadPoolExecutorDispatcher
halt() - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
halt() - Method in class reactor.event.dispatch.WorkQueueDispatcher
hashCode() - Method in class reactor.event.selector.Selectors.AnonymousKey
hashCode() - Method in class reactor.tuple.Tuple
hashCode() - Method in class reactor.util.LinkedMultiValueMap
hashCode(boolean) - Static method in class reactor.util.ObjectUtils: Return the same value as Boolean.hashCode()}.
hashCode(double) - Static method in class reactor.util.ObjectUtils: Return the same value as Double.hashCode()}.
hashCode(float) - Static method in class reactor.util.ObjectUtils: Return the same value as Float.hashCode()}.
hashCode(long) - Static method in class reactor.util.ObjectUtils: Return the same value as Long.hashCode()}.
HashWheelTimer - Class in reactor.timer: Hash Wheel Timer, as per the paper: Hashed and hierarchical timing wheels: http://www.cs.columbia.edu/~nahum/w6998/papers/ton97-timing-wheels.pdf More comprehensive slides, explaining the paper can be found here: http://www.cse.wustl.edu/~cdgill/courses/cs6874/TimingWheels.ppt Hash Wheel timer is an approximated timer that allows performant execution of larger amount of tasks with better performance compared to traditional scheduling.
HashWheelTimer() - Constructor for class reactor.timer.HashWheelTimer: Create a new HashWheelTimer using the given with default resolution of 100 milliseconds and default wheel size.
HashWheelTimer(int) - Constructor for class reactor.timer.HashWheelTimer: Create a new HashWheelTimer using the given timer resolution.
HashWheelTimer(int, int, HashWheelTimer.WaitStrategy) - Constructor for class reactor.timer.HashWheelTimer: Create a new HashWheelTimer using the given timer and .
HashWheelTimer(String, int, int, HashWheelTimer.WaitStrategy, Executor) - Constructor for class reactor.timer.HashWheelTimer: Create a new HashWheelTimer using the given timer and .
HashWheelTimer.BusySpinWait - Class in reactor.timer: BusySpin wait strategy.
HashWheelTimer.SleepWait - Class in reactor.timer: Sleep wait strategy.
HashWheelTimer.TimerRegistration<T extends Consumer<java.lang.Long>> - Class in reactor.timer: Timer Registration
HashWheelTimer.WaitStrategy - Interface in reactor.timer: Wait strategy for the timer
HashWheelTimer.YieldingWait - Class in reactor.timer: Yielding wait strategy.
hasLength(String, String) - Static method in class reactor.util.Assert: Assert that the given String is not empty; that is, it must not be null and not the empty String.
hasLength(String) - Static method in class reactor.util.Assert: Assert that the given String is not empty; that is, it must not be null and not the empty String.
hasLength(CharSequence) - Static method in class reactor.util.StringUtils: Check that the given CharSequence is neither null nor of length 0.
hasLength(String) - Static method in class reactor.util.StringUtils: Check that the given String is neither null nor of length 0.
hasNext() - Method in class reactor.queue.IndexedChronicleQueuePersistor
hasNext() - Method in class reactor.queue.InMemoryQueuePersistor
hasNext() - Method in interface reactor.queue.QueuePersistor: Are there more items waiting to be returned?
hasText(String, String) - Static method in class reactor.util.Assert: Assert that the given String has valid text content; that is, it must not be null and must contain at least one non-whitespace character.
hasText(String) - Static method in class reactor.util.Assert: Assert that the given String has valid text content; that is, it must not be null and must contain at least one non-whitespace character.
hasText(CharSequence) - Static method in class reactor.util.StringUtils: Check whether the given CharSequence has actual text.
hasText(String) - Static method in class reactor.util.StringUtils: Check whether the given String has actual text.
hasUniqueObject(Collection) - Static method in class reactor.util.CollectionUtils: Determine whether the given Collection only contains a single unique object.
HeaderResolver - Interface in reactor.event.selector: Responsible for extracting any applicable headers from a key.
Headers(Map<String, Object>) - Constructor for class reactor.event.Event.Headers: Creates a new Headers instance by copying the contents of the given headers Map.
Headers() - Constructor for class reactor.event.Event.Headers: Create an empty Headers

I

id - Variable in class reactor.core.processor.Operation
Identifiable<ID> - Interface in reactor.support
identityToString(Object) - Static method in class reactor.util.ObjectUtils: Return a String representation of an object's overall identity.
IndexedChronicleQueuePersistor<T> - Class in reactor.queue: A QueuePersistor implementation that uses a Java Chronicle IndexedChronicle to persist items in the queue.
IndexedChronicleQueuePersistor(String) - Constructor for class reactor.queue.IndexedChronicleQueuePersistor: Create an IndexedChronicleQueuePersistor based on the given base path.
IndexedChronicleQueuePersistor(String, Codec<Buffer, T, T>, boolean, boolean, ChronicleConfig) - Constructor for class reactor.queue.IndexedChronicleQueuePersistor: Create an IndexedChronicleQueuePersistor based on the given base path, encoder and decoder.
indexFileCapacity(int) - Method in class reactor.queue.spec.PersistentQueueSpec
indexFileCapacity(boolean) - Method in class reactor.queue.spec.PersistentQueueSpec
indexFileExcerpts(int) - Method in class reactor.queue.spec.PersistentQueueSpec
indexOf(byte) - Method in class reactor.io.Buffer: Search the buffer and find the position of the first occurrence of the given byte.
indexOf(byte, int, int) - Method in class reactor.io.Buffer: Search the buffer and find the position of the first occurrence of the given byte staring at the start position and searching until (and including) the end position.
InMemoryQueuePersistor<T> - Class in reactor.queue: A QueuePersistor implementations that stores items in-memory.
InMemoryQueuePersistor() - Constructor for class reactor.queue.InMemoryQueuePersistor
inputStream() - Method in class reactor.io.Buffer: Create an InputStream capable of reading the bytes from the internal ByteBuffer.
intValue() - Method in class reactor.alloc.RecyclableNumber
invoke(Consumer<?>, Class<? extends T>, Object) - Method in class reactor.event.routing.ArgumentConvertingConsumerInvoker
invoke(Consumer<?>, Class<? extends T>, Object) - Method in interface reactor.event.routing.ConsumerInvoker: Invoke a Consumer.
IoUtils - Class in reactor.util: IO-related utility methods
isArray(Object) - Static method in class reactor.util.ObjectUtils: Determine whether the given object is an array: either an Object array or a primitive array.
isAssignable(Class<?>, Class<?>) - Static method in class reactor.util.Assert: Assert that superType.isAssignableFrom(subType) is true.
isAssignable(Class<?>, Class<?>, String) - Static method in class reactor.util.Assert: Assert that superType.isAssignableFrom(subType) is true.
isCancelAfterUse() - Method in class reactor.event.registry.CachableRegistration
isCancelAfterUse() - Method in interface reactor.event.registry.Registration: Whether to cancel this Registration after use or not.
isCancelAfterUse() - Method in class reactor.timer.HashWheelTimer.TimerRegistration
isCancelled() - Method in class reactor.event.registry.CachableRegistration
isCancelled() - Method in interface reactor.event.registry.Registration: Has this been cancelled?
isCancelled() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Check whether the current Registration is cancelled
isCheckedException(Throwable) - Static method in class reactor.util.ObjectUtils: Return whether the given throwable is a checked exception: that is, neither a RuntimeException nor an Error.
isCompatibleWithThrowsClause(Throwable, Class[]) - Static method in class reactor.util.ObjectUtils: Check whether the given exception is compatible with the exceptions declared in a throws clause.
isComplete() - Method in class reactor.core.composable.Promise: Indicates whether this Promise has been completed with either an error or a value
isDynamic() - Method in class reactor.io.Buffer: Whether this Buffer is fixed-length or not.
isEmpty(Collection) - Static method in class reactor.util.CollectionUtils: Return true if the supplied Collection is null or empty.
isEmpty(Map) - Static method in class reactor.util.CollectionUtils: Return true if the supplied Map is null or empty.
isEmpty() - Method in class reactor.util.LinkedMultiValueMap
isEmpty(Object[]) - Static method in class reactor.util.ObjectUtils: Determine whether the given array is empty: i.e.
isEmpty(Object) - Static method in class reactor.util.StringUtils: Check whether the given String is empty.
isError() - Method in class reactor.core.composable.Promise: Indicates whether this Promise has been completed with an error.
isInContext() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher: Dispatchers can be traced through a contextClassLoader to let producers adapting their dispatching strategy
isInstanceOf(Class<?>, Object) - Static method in class reactor.util.Assert: Assert that the provided object is an instance of the provided class.
isInstanceOf(Class<?>, Object, String) - Static method in class reactor.util.Assert: Assert that the provided object is an instance of the provided class.
isNull(Object, String) - Static method in class reactor.util.Assert: Assert that an object is null .
isNull(Object) - Static method in class reactor.util.Assert: Assert that an object is null .
isOpen() - Method in class reactor.io.Buffer
isPaused() - Method in class reactor.event.registry.CachableRegistration
isPaused() - Method in interface reactor.event.registry.Registration: Whether this Registration has been paused or not.
isPaused() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Check whether the current Registration is paused
isPending() - Method in class reactor.core.composable.Promise: Indicates whether this Promise has yet to be completed with a value or an error.
isSuccess() - Method in class reactor.core.composable.Promise: Indicates whether this Promise has been successfully completed a value.
isTrue(boolean, String) - Static method in class reactor.util.Assert: Assert a boolean expression, throwing IllegalArgumentException if the test result is false.
isTrue(boolean) - Static method in class reactor.util.Assert: Assert a boolean expression, throwing IllegalArgumentException if the test result is false.
iterator() - Method in class reactor.core.Environment
iterator() - Method in class reactor.event.Event.Headers: Returns an unmodifiable Iterator over a copy of this Headers' contents.
iterator() - Method in class reactor.event.registry.CachingRegistry
iterator() - Method in class reactor.function.support.DelegatingConsumer
iterator() - Method in class reactor.io.Buffer
iterator() - Method in class reactor.queue.IndexedChronicleQueuePersistor
iterator() - Method in class reactor.queue.InMemoryQueuePersistor
iterator() - Method in class reactor.queue.PersistentQueue
iterator() - Method in class reactor.tuple.Tuple
iterator() - Method in class reactor.util.PartitionedReferencePile

J

J(String, Filter...) - Static method in class reactor.io.selector.JsonPathSelector
JacksonJsonCodec<IN,OUT> - Class in reactor.io.encoding.json
JacksonJsonCodec() - Constructor for class reactor.io.encoding.json.JacksonJsonCodec
JacksonJsonCodec(ObjectMapper) - Constructor for class reactor.io.encoding.json.JacksonJsonCodec
JavaSerializationCodec<T> - Class in reactor.io.encoding: Codec to transform Java objects into Buffers and visa-versa.
JavaSerializationCodec() - Constructor for class reactor.io.encoding.JavaSerializationCodec
join(Function<?, V>...) - Method in class reactor.core.fork.ForkJoinPool: Asynchronously submit the given tasks, one submit per task, to the configured Executor and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().
join(Collection<Function<?, V>>) - Method in class reactor.core.fork.ForkJoinPool: Asynchronously submit the given tasks, one submit per task, to the configured Executor and collecting the results in a List that will be the fulfillment of the Promise returned from ForkJoinTask.compose().
JsonCodec<IN,OUT> - Class in reactor.io.encoding.json: A codec for decoding JSON into Java objects and encoding Java objects into JSON.
JsonCodec(Class<IN>) - Constructor for class reactor.io.encoding.json.JsonCodec: Creates a new JsonCodec that will create instances of inputType when decoding.
JsonCodec(Class<IN>, Module) - Constructor for class reactor.io.encoding.json.JsonCodec: Creates a new JsonCodec that will create instances of inputType when decoding.
JsonPathSelector - Class in reactor.io.selector
JsonPathSelector(ObjectMapper, String, Filter...) - Constructor for class reactor.io.selector.JsonPathSelector
JsonPathSelector(String, Filter...) - Constructor for class reactor.io.selector.JsonPathSelector
jsonPathSelector(String, Filter...) - Static method in class reactor.io.selector.JsonPathSelector

K

key - Variable in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
keySet() - Method in class reactor.util.LinkedMultiValueMap
KryoCodec<IN,OUT> - Class in reactor.io.encoding.kryo
KryoCodec() - Constructor for class reactor.io.encoding.kryo.KryoCodec
KryoCodec(Kryo, boolean) - Constructor for class reactor.io.encoding.kryo.KryoCodec

L

last() - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be only the last value of each batch.
last(int) - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be only the last value of each batch.
last() - Method in class reactor.io.Buffer: Get the last byte from this Buffer.
lastId() - Method in class reactor.queue.IndexedChronicleQueuePersistor
lastId() - Method in class reactor.queue.InMemoryQueuePersistor
lastId() - Method in interface reactor.queue.QueuePersistor: Get the value of the last item to have been persisted.
LengthFieldCodec<IN,OUT> - Class in reactor.io.encoding: A codec that uses a length-field at the start of each chunk to denote the chunk's size.
LengthFieldCodec(Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.LengthFieldCodec: Create a length-field codec that reads the first integer as the length of the remaining message.
LengthFieldCodec(int, Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.LengthFieldCodec: Create a length-field codec that reads the first short, integer, or long as the length of the remaining message, and prepends a short, integer, long to its output.
limit(int) - Method in class reactor.io.Buffer: Sets this buffer's limit.
limit() - Method in class reactor.io.Buffer: Provides the current limit of the internal ByteBuffer.
LINE_FEED_CODEC - Static variable in class reactor.io.encoding.StandardCodecs: A DelimitedCodec that works with String data delimited by a line-feed ('\n') character
link(Composable<?>) - Method in class reactor.core.composable.spec.DeferredPromiseSpec: Configures the promise to have the given parent
LinkedCaseInsensitiveMap<V> - Class in reactor.util: LinkedHashMap variant that stores String keys in a case-insensitive manner, for example for key-based access in a results table.
LinkedCaseInsensitiveMap() - Constructor for class reactor.util.LinkedCaseInsensitiveMap: Create a new LinkedCaseInsensitiveMap for the default Locale.
LinkedCaseInsensitiveMap(Locale) - Constructor for class reactor.util.LinkedCaseInsensitiveMap: Create a new LinkedCaseInsensitiveMap that stores lower-case keys according to the given Locale.
LinkedCaseInsensitiveMap(int) - Constructor for class reactor.util.LinkedCaseInsensitiveMap: Create a new LinkedCaseInsensitiveMap that wraps a LinkedHashMap with the given initial capacity and stores lower-case keys according to the default Locale.
LinkedCaseInsensitiveMap(int, Locale) - Constructor for class reactor.util.LinkedCaseInsensitiveMap: Create a new LinkedCaseInsensitiveMap that wraps a LinkedHashMap with the given initial capacity and stores lower-case keys according to the given Locale.
LinkedMultiValueMap<K,V> - Class in reactor.util: Simple implementation of MultiValueMap that wraps a LinkedHashMap, storing multiple values in a LinkedList.
LinkedMultiValueMap() - Constructor for class reactor.util.LinkedMultiValueMap: Create a new LinkedMultiValueMap that wraps a LinkedHashMap.
LinkedMultiValueMap(int) - Constructor for class reactor.util.LinkedMultiValueMap: Create a new LinkedMultiValueMap that wraps a LinkedHashMap with the given initial capacity.
LinkedMultiValueMap(Map<K, List<V>>) - Constructor for class reactor.util.LinkedMultiValueMap: Copy constructor: Create a new LinkedMultiValueMap with the same mappings as the specified Map.
LoadingPool<T> - Class in reactor.pool: Deprecated.
LoadingPool(Supplier<T>, Supplier<Long>, int, long) - Constructor for class reactor.pool.LoadingPool: Deprecated.

Creates a new LoadingPool that will use the supplier to
loadProfile(String) - Method in class reactor.core.configuration.PropertiesConfigurationReader
lock - Variable in class reactor.core.action.BatchAction
longValue() - Method in class reactor.alloc.RecyclableNumber

M

makeAllocator(Class<T>) - Method in class reactor.event.alloc.EventAllocator: Make a new allocator for Events with generic type of
map(Function<T, V>) - Method in class reactor.core.composable.Composable: Assign the given Function to transform the incoming value T into a V and pass it into another Composable.
map(Function<T, V>) - Method in class reactor.core.composable.Promise
map(Function<T, V>) - Method in class reactor.core.composable.Stream
MapAction<T,V> - Class in reactor.core.action
MapAction(Function<T, V>, Observable, Object, Object) - Constructor for class reactor.core.action.MapAction
mapMany(Function<T, C>) - Method in class reactor.core.composable.Composable: Assign the given Function to transform the incoming value T into a Composable<V> and pass it into another Composable.
mapMany(Function<T, C>) - Method in class reactor.core.composable.Promise
mapMany(Function<T, C>) - Method in class reactor.core.composable.Stream
MapManyAction<T,V,C extends Composable<V>> - Class in reactor.core.action
MapManyAction(Function<T, C>, Observable, Object, Object, Object) - Constructor for class reactor.core.action.MapManyAction
match(String) - Method in class reactor.event.selector.UriPathTemplate: Matches the template against the given uri returning a map of path parameters extracted from the uri, keyed by the names in the template.
matchAll() - Static method in class reactor.event.selector.Selectors: Creates a Selector that matches all objects.
MatchAllSelector - Class in reactor.event.selector: Implementation of Selector that matches all objects.
MatchAllSelector() - Constructor for class reactor.event.selector.MatchAllSelector
matches(Object) - Method in class reactor.event.selector.ClassSelector
matches(Object) - Method in class reactor.event.selector.MatchAllSelector
matches(Object) - Method in class reactor.event.selector.ObjectSelector
matches(Object) - Method in class reactor.event.selector.PredicateSelector
matches(Object) - Method in class reactor.event.selector.RegexSelector
matches(Object) - Method in interface reactor.event.selector.Selector: Indicates whether this Selector matches the key.
matches(Object) - Method in class reactor.event.selector.SetMembershipSelector
matches(Object) - Method in class reactor.event.selector.UriPathSelector
matches(String) - Method in class reactor.event.selector.UriPathTemplate: Tests the given uri against this template, returning true if the uri matches the template, false otherwise.
matches(Object) - Method in class reactor.event.selector.UriSelector
matches(Object) - Method in class reactor.io.selector.JsonPathSelector
MAX_BUFFER_SIZE - Static variable in class reactor.io.Buffer: The maximum allowed buffer size in bytes.
merge(Composable<T>...) - Method in class reactor.core.composable.Composable: this#connect(Composable) all the passed to this Composable, merging values streams into the current pipeline.
merge(Composable<T>...) - Method in class reactor.core.composable.Promise
merge(Composable<T>...) - Method in class reactor.core.composable.Stream
MERGE_FLUSH - Static variable in class reactor.core.action.MapManyAction
mergeArrayIntoCollection(Object, Collection) - Static method in class reactor.util.CollectionUtils: Merge the given array into the given Collection.
mergePropertiesIntoMap(Properties, Map) - Static method in class reactor.util.CollectionUtils: Merge the given Properties instance into the given Map, copying all properties (key-value pairs) over.
mergeStringArrays(String[], String[]) - Static method in class reactor.util.StringUtils: Merge the given String arrays into one, with overlapping array elements only included once.
methodNameToNotificationKey(String) - Static method in class reactor.core.dynamic.reflect.support.MethodNameUtils: Strip the "notify" when a method name and split the camel-case into a dot-separated String.
methodNameToSelectorName(String) - Static method in class reactor.core.dynamic.reflect.support.MethodNameUtils: Strip the "on" or "notify" when a method name and split the camel-case into a dot-separated String.
MethodNameUtils - Class in reactor.core.dynamic.reflect.support
MethodNameUtils() - Constructor for class reactor.core.dynamic.reflect.support.MethodNameUtils
MethodNotificationKeyResolver - Interface in reactor.core.dynamic.reflect: When given a Method, a MethodNotificationKeyResolver will attempt to return a notification key for the method.
MethodSelectorResolver - Interface in reactor.core.dynamic.reflect: When given a Method, a MethodSelectorResolver will attempt to return a Selector for the method.
minimiseFootprint(boolean) - Method in class reactor.queue.spec.PersistentQueueSpec
movingWindow(int, int) - Method in class reactor.core.composable.Stream: Collect incoming values into an internal array, providing a List that will be pushed into the returned Stream every specified in milliseconds.
movingWindow(int, TimeUnit, int) - Method in class reactor.core.composable.Stream: Collect incoming values into an internal array, providing a List that will be pushed into the returned Stream every specified time from the and a .
movingWindow(int, TimeUnit, int, int) - Method in class reactor.core.composable.Stream: Collect incoming values into an internal array, providing a List that will be pushed into the returned Stream every specified time from the and a after an initial in milliseconds.
movingWindow(int, TimeUnit, int, int, Timer) - Method in class reactor.core.composable.Stream: Collect incoming values into an internal array, providing a List that will be pushed into the returned Stream every specified time from the and a after an initial in milliseconds.
MovingWindowAction<T> - Class in reactor.core.action: MovingWindowAction is collecting maximum events on a stream until is reached, after that steams collected events further, and continues collecting without clearing the list.
MovingWindowAction(Observable, Object, Object, Timer, int, TimeUnit, int, int) - Constructor for class reactor.core.action.MovingWindowAction
multiThreadedProducer() - Method in class reactor.core.processor.spec.ProcessorSpec: Protect against publication of data events from multiple producer threads.
MultiThreadTask() - Constructor for class reactor.event.dispatch.AbstractMultiThreadDispatcher.MultiThreadTask
MultiValueMap<K,V> - Interface in reactor.util: Extension of the Map interface that stores multiple values.

N

name(String) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: Name of the RingBufferAllocator.
NamedDaemonThreadFactory - Class in reactor.support: A thread factory that creates named daemon threads.
NamedDaemonThreadFactory(String) - Constructor for class reactor.support.NamedDaemonThreadFactory: Creates a new thread factory that will name its threads <prefix>-<n>, where <prefix> is the given prefix and <n> is the count of threads created thus far by this class.
NamedDaemonThreadFactory(String, ClassLoader) - Constructor for class reactor.support.NamedDaemonThreadFactory: Creates a new thread factory that will name its threads <prefix>-<n>, where <prefix> is the given prefix and <n> is the count of threads created thus far by this class.
NamedDaemonThreadFactory(String, ClassLoader, Thread.UncaughtExceptionHandler) - Constructor for class reactor.support.NamedDaemonThreadFactory
negate(Predicate<? super T>) - Static method in class reactor.function.Predicates: Returns a Predicate which negates the given Predicate.
newComposable() - Method in class reactor.core.composable.Composable: Create a Composable that is compatible with the subclass of Composable in use.
newComposable() - Method in class reactor.core.composable.Promise
newComposable() - Method in class reactor.core.composable.Stream
newComposable(int) - Method in class reactor.core.composable.Stream
newThread(Runnable) - Method in class reactor.support.NamedDaemonThreadFactory
next(Composable<T>) - Static method in class reactor.core.composable.spec.Promises: Consume the next value of the given Composable and fulfill the returned Promise on the next value.
next() - Method in class reactor.function.support.Resequencer
nextPartitionId() - Method in class reactor.alloc.PartitionedAllocator
nextPartitionId() - Method in class reactor.alloc.ThreadPartitionedAllocator
NoArgConstructorFactory<T> - Class in reactor.alloc.factory: A Supplier implementation that simply instantiates objects using reflection from a no-arg constructor.
NoArgConstructorFactory(Class<T>) - Constructor for class reactor.alloc.factory.NoArgConstructorFactory
noNullElements(Object[], String) - Static method in class reactor.util.Assert: Assert that an array has no null elements.
noNullElements(Object[]) - Static method in class reactor.util.Assert: Assert that an array has no null elements.
notEmpty(Object[], String) - Static method in class reactor.util.Assert: Assert that an array has elements; that is, it must not be null and must have at least one element.
notEmpty(Object[]) - Static method in class reactor.util.Assert: Assert that an array has elements; that is, it must not be null and must have at least one element.
notEmpty(Collection, String) - Static method in class reactor.util.Assert: Assert that a collection has elements; that is, it must not be null and must have at least one element.
notEmpty(Collection) - Static method in class reactor.util.Assert: Assert that a collection has elements; that is, it must not be null and must have at least one element.
notEmpty(Map, String) - Static method in class reactor.util.Assert: Assert that a Map has entries; that is, it must not be null and must have at least one entry.
notEmpty(Map) - Static method in class reactor.util.Assert: Assert that a Map has entries; that is, it must not be null and must have at least one entry.
Notify - Annotation Type in reactor.core.dynamic.annotation: Annotation to denote that a method should proxy a call to an underlying Reactor.notify(Object, reactor.event.Event) or Reactor.notify(Object) call.
notify(Object, E, Consumer<E>) - Method in interface reactor.core.Observable: Notify this component that an Event is ready to be processed and accept onComplete after dispatching.
notify(Object, E) - Method in interface reactor.core.Observable: Notify this component that an Event is ready to be processed.
notify(Object, S) - Method in interface reactor.core.Observable: Notify this component that the given Supplier can provide an event that's ready to be processed.
notify(Object) - Method in interface reactor.core.Observable: Notify this component that the consumers registered with a Selector that matches the key should be triggered with a null input argument.
notify(Object, E, Consumer<E>) - Method in class reactor.core.Reactor
notify(Object, E) - Method in class reactor.core.Reactor
notify(Object, S) - Method in class reactor.core.Reactor
notify(Object) - Method in class reactor.core.Reactor
NotifyConsumer<T> - Class in reactor.core.support: A Consumer that notifies an observable of each value that it has accepted.
NotifyConsumer(Object, Observable) - Constructor for class reactor.core.support.NotifyConsumer: Creates a new NotifyConsumer that will notify the given observable using the given notifyKey.
notifyError(Throwable) - Method in class reactor.core.action.Action: Notify this Composable that an error is being propagated through this Observable.
notifyError(Throwable) - Method in class reactor.core.action.BatchAction
notifyValue(Event<?>) - Method in class reactor.core.action.Action
notNull(Object, String) - Static method in class reactor.util.Assert: Assert that an object is not null .
notNull(Object) - Static method in class reactor.util.Assert: Assert that an object is not null .
nullSafeClassName(Object) - Static method in class reactor.util.ObjectUtils: Determine the class name for the given object.
nullSafeEquals(Object, Object) - Static method in class reactor.util.ObjectUtils: Determine if the given objects are equal, returning true if both are null or false if only one is null.
nullSafeHashCode(Object) - Static method in class reactor.util.ObjectUtils: Return a hash code for the given object; typically the value of Object.hashCode().
nullSafeHashCode(Object[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(boolean[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(byte[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(char[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(double[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(float[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(int[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(long[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeHashCode(short[]) - Static method in class reactor.util.ObjectUtils: Return a hash code based on the contents of the specified array.
nullSafeToString(Object) - Static method in class reactor.util.ObjectUtils: Return a String representation of the specified Object.
nullSafeToString(Object[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(boolean[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(byte[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(char[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(double[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(float[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(int[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(long[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.
nullSafeToString(short[]) - Static method in class reactor.util.ObjectUtils: Return a String representation of the contents of the specified array.

O

object(T) - Static method in class reactor.event.selector.Selectors: Creates a Selector based on the given object.
ObjectSelector<T> - Class in reactor.event.selector: Selector implementation that uses the Object.hashCode() and Object.equals(Object) methods of the internal object to determine a match.
ObjectSelector(T) - Constructor for class reactor.event.selector.ObjectSelector: Create a new Selector instance from the given object.
objectSelector(T) - Static method in class reactor.event.selector.ObjectSelector: Helper method to create a Selector from the given object.
ObjectUtils - Class in reactor.util: Miscellaneous object utility methods.
ObjectUtils() - Constructor for class reactor.util.ObjectUtils
Observable - Interface in reactor.core: Basic unit of event handling in Reactor.
of(T1) - Static method in class reactor.tuple.Tuple: Create a Tuple1 with the given object.
of(T1, T2) - Static method in class reactor.tuple.Tuple: Create a Tuple2 with the given objects.
of(T1, T2, T3) - Static method in class reactor.tuple.Tuple: Create a Tuple3 with the given objects.
of(T1, T2, T3, T4) - Static method in class reactor.tuple.Tuple: Create a Tuple4 with the given objects.
of(T1, T2, T3, T4, T5) - Static method in class reactor.tuple.Tuple: Create a Tuple5 with the given objects.
of(T1, T2, T3, T4, T5, T6) - Static method in class reactor.tuple.Tuple: Create a Tuple6 with the given objects.
of(T1, T2, T3, T4, T5, T6, T7) - Static method in class reactor.tuple.Tuple: Create a Tuple7 with the given objects.
of(T1, T2, T3, T4, T5, T6, T7, T8) - Static method in class reactor.tuple.Tuple: Create a Tuple8 with the given objects.
of(T1, T2, T3, T4, T5, T6, T7, T8, Object...) - Static method in class reactor.tuple.Tuple: Create a TupleN with the given objects.
offer() - Method in class reactor.queue.IndexedChronicleQueuePersistor
offer() - Method in class reactor.queue.InMemoryQueuePersistor
offer(T) - Method in class reactor.queue.PersistentQueue
offer() - Method in interface reactor.queue.QueuePersistor: Returns a Function that will persist the item and return a Long id for the item.
on(Observable, Selector, Object) - Static method in class reactor.core.composable.spec.Streams: Attach a Stream to the Observable with the specified Selector and key.
on(Observable, Selector) - Static method in class reactor.core.composable.spec.Streams: Attach a Stream to the Observable with the specified Selector.
On - Annotation Type in reactor.core.dynamic.annotation: Annotation to denote that a method should proxy a call to Reactor.on(Selector, Consumer).
on(Selector, Consumer<E>) - Method in interface reactor.core.Observable: Register a Consumer to be triggered when a notification matches the given Selector.
on(Selector, Consumer<E>) - Method in class reactor.core.Reactor
once(Consumer<T>) - Static method in class reactor.function.support.SingleUseConsumer: Static helper method for creating SingleUseConsumer SingleUseConsumers in code with a little less noise.
onComplete(Consumer<Promise<T>>) - Method in class reactor.core.composable.Promise: Assign a Consumer that will either be invoked later, when the Promise is completed by either setting a value or propagating an error, or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the current Dispatcher.
onError(Consumer<Throwable>) - Method in class reactor.core.composable.Promise: Assign a Consumer that will either be invoked later, when the Promise is completed with an error, or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the current Dispatcher.
onSuccess(Consumer<T>) - Method in class reactor.core.composable.Promise: Assign a Consumer that will either be invoked later, when the Promise is successfully completed with a value, or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the current Dispatcher.
Operation<T> - Class in reactor.core.processor: A Operation represents the payload that gets (re) used in the processor.
or(Predicate<? super T>, Predicate<? super T>) - Static method in class reactor.function.Predicates: Returns a Predicate which evaluates to true if either this predicate or the provided predicate evaluate to true.
ORIGIN - Static variable in class reactor.event.Event.Headers: The name of the origin header
override(Event<T>) - Method in class reactor.event.Event

P

ParkWaitStrategy - Class in reactor.event.dispatch
ParkWaitStrategy() - Constructor for class reactor.event.dispatch.ParkWaitStrategy
ParkWaitStrategy(long) - Constructor for class reactor.event.dispatch.ParkWaitStrategy
parseInt(Buffer, int, int) - Static method in class reactor.io.Buffer: Very efficient method for parsing an Integer from the given Buffer range.
parseInt(Buffer) - Static method in class reactor.io.Buffer: Very efficient method for parsing an Integer from the given Buffer.
parseLocaleString(String) - Static method in class reactor.util.StringUtils: Parse the given localeString value into a Locale.
parseLong(Buffer, int, int) - Static method in class reactor.io.Buffer: Very efficient method for parsing a Long from the given Buffer range.
parseLong(Buffer) - Static method in class reactor.io.Buffer: Very efficient method for parsing a Long from the given Buffer.
PartitionedAllocator<T extends Recyclable> - Class in reactor.alloc: An Allocator implementation that allocates a single object per thread, similar to a ThreadLocal but more efficient.
PartitionedAllocator(Supplier<T>) - Constructor for class reactor.alloc.PartitionedAllocator
PartitionedReferencePile<T> - Class in reactor.util
PartitionedReferencePile(Supplier<T>) - Constructor for class reactor.util.PartitionedReferencePile
PartitionedReferencePile(int, Supplier<T>) - Constructor for class reactor.util.PartitionedReferencePile
PASS_THROUGH_CODEC - Static variable in class reactor.io.encoding.StandardCodecs
PassThroughCodec<SRC> - Class in reactor.io.encoding: A simple Codec that uses the source object as both input and output.
PassThroughCodec() - Constructor for class reactor.io.encoding.PassThroughCodec
PassThroughFilter - Class in reactor.filter: A Filter implementation that performs no filtering, returning the items as-is.
PassThroughFilter() - Constructor for class reactor.filter.PassThroughFilter
pathEquals(String, String) - Static method in class reactor.util.StringUtils: Compare two paths after normalization of them.
Pausable - Interface in reactor.event.lifecycle
pause() - Method in class reactor.core.action.WindowAction
pause() - Method in interface reactor.event.lifecycle.Pausable: Pause this Pausable.
pause() - Method in class reactor.event.registry.CachableRegistration
pause() - Method in interface reactor.event.registry.Registration: Pause this Registration.
pause() - Method in class reactor.function.support.Poller: Pausing polling for values from this Supplier.
pause() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Pause the current Regisration
peek() - Method in class reactor.queue.PersistentQueue
PersistentQueue<T> - Class in reactor.queue: A PersistentQueue is a Queue implementation that delegates the actual storage of the elements in the queue to a QueuePersistor.
PersistentQueue(QueuePersistor<T>) - Constructor for class reactor.queue.PersistentQueue: Create a PersistentQueue using the given QueuePersistor.
PersistentQueueSpec<T> - Class in reactor.queue.spec: Helper spec to create a PersistentQueue instance.
PersistentQueueSpec() - Constructor for class reactor.queue.spec.PersistentQueueSpec
Pipeline<T> - Interface in reactor.core.action: Component that can be injected with Actions and consume flush events for releasing buffer owned by the pipeline
poll() - Method in class reactor.queue.PersistentQueue
Poller<T> - Class in reactor.function.support: A Poller funnels non-null values retrieved from a Supplier to the given Consumer using a separate thread created for each instance of a Poller.
Poller(Supplier<T>, Consumer<T>) - Constructor for class reactor.function.support.Poller: Poll the given Supplier for non-null values and pass them to the given Consumer.
Poller(Supplier<T>, Consumer<T>, boolean) - Constructor for class reactor.function.support.Poller: Poll the given Supplier for non-null values and pass them to the given Consumer.
Pool<T> - Interface in reactor.pool: Deprecated.
position() - Method in class reactor.io.Buffer: Provides the current position in the internal ByteBuffer.
position(int) - Method in class reactor.io.Buffer: Sets this buffer's position.
predicate(Predicate<Object>) - Static method in class reactor.event.selector.Selectors: Creates a Selector based on the given Predicate.
Predicate<T> - Interface in reactor.function: Determines if the input object matches some criteria.
Predicates - Class in reactor.function
Predicates() - Constructor for class reactor.function.Predicates
PredicateSelector - Class in reactor.event.selector: Implementation of Selector that delegates the work of matching an object to the given Predicate.
PredicateSelector(Predicate<Object>) - Constructor for class reactor.event.selector.PredicateSelector
predicateSelector(Predicate<Object>) - Static method in class reactor.event.selector.PredicateSelector: Creates a Selector based on the given Predicate.
prepare(Object) - Method in interface reactor.core.Observable: Create an optimized path for publishing notifications to the given key.
prepare() - Method in class reactor.core.processor.Processor: Prepare an Operation by allocating it from the buffer and preparing it to be submitted once Operation.commit() is invoked.
prepare(Object) - Method in class reactor.core.Reactor
prepend(Buffer) - Method in class reactor.io.Buffer: Prepend the given Buffer to this Buffer.
prepend(String) - Method in class reactor.io.Buffer: Prepend the given String to this Buffer.
prepend(byte[]) - Method in class reactor.io.Buffer: Prepend the given byte[] array to this Buffer.
prepend(ByteBuffer) - Method in class reactor.io.Buffer: Prepend the given ByteBuffer to this Buffer.
prepend(byte) - Method in class reactor.io.Buffer: Prepend the given byte to this Buffer.
prepend(char) - Method in class reactor.io.Buffer: Prepend the given char to this existing Buffer.
prepend(short) - Method in class reactor.io.Buffer: Prepend the given short to this Buffer.
prepend(int) - Method in class reactor.io.Buffer: Prepend the given int to this Buffer.
prepend(long) - Method in class reactor.io.Buffer: Prepend the given long to this Buffer.
Processor<T> - Class in reactor.core.processor: A Processor is a highly-efficient data processor that is backed by an LMAX Disruptor RingBuffer.
Processor(Supplier<T>, Consumer<T>, Registry<Consumer<Throwable>>, WaitStrategy, boolean, int) - Constructor for class reactor.core.processor.Processor
PROCESSORS - Static variable in class reactor.core.Environment: The number of processors available to the runtime
ProcessorSpec<T> - Class in reactor.core.processor.spec: Specification class to create Processors.
ProcessorSpec() - Constructor for class reactor.core.processor.spec.ProcessorSpec
producerType(ProducerType) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: Specify single or multi-threaded producer.
Promise<T> - Class in reactor.core.composable: A Promise is a stateful event processor that accepts a single value or error.
Promise(Observable, Environment, Composable<?>) - Constructor for class reactor.core.composable.Promise: Creates a new unfulfilled promise.
Promise(T, Observable, Environment) - Constructor for class reactor.core.composable.Promise: Creates a new promise that has been fulfilled with the given value.
Promise(Throwable, Observable, Environment) - Constructor for class reactor.core.composable.Promise: Creates a new promise that has failed with the given error.
Promises - Class in reactor.core.composable.spec: Helper methods for creating Deferred instances, backed by a Promise.
Promises() - Constructor for class reactor.core.composable.spec.Promises
PromiseSpec<T> - Class in reactor.core.composable.spec: A helper class for specifying a Promise.
PromiseSpec() - Constructor for class reactor.core.composable.spec.PromiseSpec
propagate(Supplier<T>) - Method in class reactor.core.composable.Composable: Create a new Composable whose values will be generated from .
propagate(Supplier<T>) - Method in class reactor.core.composable.Promise
propagate(Iterable<T>) - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be each iterated item from Every time flush is triggered, is drained.
propagate(Supplier<T>) - Method in class reactor.core.composable.Stream
PropertiesConfigurationReader - Class in reactor.core.configuration: A ConfigurationReader that reads the configuration from properties files and System properties.
PropertiesConfigurationReader() - Constructor for class reactor.core.configuration.PropertiesConfigurationReader: Creates a new PropertiesConfigurationReader that, by default, will load its configuration from META-INF/reactor/default.properties.
PropertiesConfigurationReader(String) - Constructor for class reactor.core.configuration.PropertiesConfigurationReader
ProtobufCodec<IN,OUT> - Class in reactor.io.encoding.protobuf
ProtobufCodec() - Constructor for class reactor.io.encoding.protobuf.ProtobufCodec
ProtobufCodec(boolean) - Constructor for class reactor.io.encoding.protobuf.ProtobufCodec
prune() - Method in class reactor.function.support.DelegatingConsumer: Remove the references to Consumers that have been removed or have gone out of scope and prune the size of the list.
put(String, V) - Method in class reactor.util.LinkedCaseInsensitiveMap
put(K, List<V>) - Method in class reactor.util.LinkedMultiValueMap
putAll(Map<? extends String, ? extends V>) - Method in class reactor.util.LinkedCaseInsensitiveMap
putAll(Map<? extends K, ? extends List<V>>) - Method in class reactor.util.LinkedMultiValueMap

Q

QueuePersistor<T> - Interface in reactor.queue: Implementations of this interface are responsible for persisting the elements of a PersistentQueue.
quote(String) - Static method in class reactor.util.StringUtils: Quote the given String with single quotes.
quoteIfString(Object) - Static method in class reactor.util.StringUtils: Turn the given Object into a String with single quotes if it is a String; keeping the Object as-is else.

R

R(String) - Static method in class reactor.event.selector.Selectors: A short-hand alias for Selectors.regex(String).
random() - Static method in class reactor.util.UUIDUtils: Create a new random UUID.
randomEventRouting() - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's EventRouter to route events to one consumer that's randomly selected from that matching consumers
RandomFilter - Class in reactor.filter: A Filter implementation that returns a single, randomly selected item.
RandomFilter() - Constructor for class reactor.filter.RandomFilter
Reactor - Class in reactor.core: A reactor is an event gateway that allows other components to register Event Consumers that can subsequently be notified of events.
Reactor(Dispatcher) - Constructor for class reactor.core.Reactor: Create a new Reactor that uses the given Dispatcher.
Reactor(Dispatcher, EventRouter) - Constructor for class reactor.core.Reactor: Create a new Reactor that uses the given Dispatcher.
Reactor(Dispatcher, EventRouter, Consumer<Throwable>, Consumer<Throwable>) - Constructor for class reactor.core.Reactor
Reactor(Registry<Consumer<? extends Event<?>>>, Dispatcher, EventRouter, Consumer<Throwable>, Consumer<Throwable>) - Constructor for class reactor.core.Reactor: Create a new Reactor that uses the given dispatacher and eventRouter.
reactor() - Static method in class reactor.core.spec.Reactors: Create a new ReactorSpec to configure a Reactor.
reactor(Environment) - Static method in class reactor.core.spec.Reactors: Create a new Reactor using the given Environment.
reactor(Environment, String) - Static method in class reactor.core.spec.Reactors: Create a new Reactor using the given Environment and dispatcher name.
reactor(Environment, Dispatcher) - Static method in class reactor.core.spec.Reactors: Create a new Reactor using the given Environment and Dispatcher.
reactor.alloc - package reactor.alloc: Pooling provides lower GC requirements by re-using components.
reactor.alloc.factory - package reactor.alloc.factory
reactor.alloc.spec - package reactor.alloc.spec
reactor.convert - package reactor.convert: Conversion from one datatype to another.
reactor.core - package reactor.core: Core components of the Reactor framework.
reactor.core.action - package reactor.core.action
reactor.core.composable - package reactor.core.composable: Composables are reactive components that provide a composition API for reacting to events rather than by using Selectors and Reactors directly.
reactor.core.composable.spec - package reactor.core.composable.spec: Specs help create Composables by providing a fluent API to specify common options.
reactor.core.configuration - package reactor.core.configuration: Components to facilitate flexible configuration of the Reactor Environment.
reactor.core.dynamic - package reactor.core.dynamic: DynamicReactors generate proxies based on user-defined interfaces and do the dirty work of wiring event handlers and makes event publishing code more succinct.
reactor.core.dynamic.annotation - package reactor.core.dynamic.annotation: Annotations to influence how proxies listen for and publish events on a Reactor.
reactor.core.dynamic.reflect - package reactor.core.dynamic.reflect: Reflection-based tools to provide dynamic proxies that take care of the logistics of wiring a Reactor and publishing events.
reactor.core.dynamic.reflect.support - package reactor.core.dynamic.reflect.support: Support classes to aid in creating reflection-based DynamicReactors.
reactor.core.fork - package reactor.core.fork
reactor.core.processor - package reactor.core.processor: A Processor is a thin wrapper around the LMAX Disruptor RingBuffer.
reactor.core.processor.spec - package reactor.core.processor.spec: Specs help create Processors by providing a fluent API to specify common options.
reactor.core.spec - package reactor.core.spec: Specs help create Reactors by providing a fluent API to specify common options.
reactor.core.spec.support - package reactor.core.spec.support: Base classes which other spec implementations can inherit from to get a standard set of options.
reactor.core.support - package reactor.core.support
reactor.event - package reactor.event: Events are the foundational abstraction within Reactor that holds the data of the event plus any additional metadata about the event like the key used to notify the component and any user-specified headers.
reactor.event.alloc - package reactor.event.alloc
reactor.event.dispatch - package reactor.event.dispatch: Dispatchers provide a way for work to be done in another thread, but unlike a standard thread pool, do so with extreme efficiency.
reactor.event.lifecycle - package reactor.event.lifecycle
reactor.event.registry - package reactor.event.registry: Registries provide a common way to retrieve items registered using a Selector.
reactor.event.routing - package reactor.event.routing: Event routing means sending a given Event to the correct Consumers.
reactor.event.selector - package reactor.event.selector: Selectors provide a way to register components to react to given key data.
reactor.event.support - package reactor.event.support
reactor.filter - package reactor.filter: Filters eliminate components from a list based on a predicate.
reactor.function - package reactor.function: This package contains the foundational abstractions on which Reactor's functional and reactive components are built.
reactor.function.batch - package reactor.function.batch: Extension of a standard Consumer that is aware of batch semantics.
reactor.function.support - package reactor.function.support
reactor.io - package reactor.io: Buffer-handling and other IO-related components.
reactor.io.encoding - package reactor.io.encoding: Components to handle encoding and decoding of objects into Buffers.
reactor.io.encoding.compress - package reactor.io.encoding.compress
reactor.io.encoding.json - package reactor.io.encoding.json: Encoding and decoding using the JSON format.
reactor.io.encoding.kryo - package reactor.io.encoding.kryo
reactor.io.encoding.protobuf - package reactor.io.encoding.protobuf
reactor.io.selector - package reactor.io.selector
reactor.pool - package reactor.pool
reactor.queue - package reactor.queue: Queue implementations that provide a persistence strategy for making sure items in the Queue aren't lost.
reactor.queue.spec - package reactor.queue.spec: Specs provide a simple fluent DSL for creating PersistentQueues by specifying common options.
Reactor.ReplyToConsumer<E extends Event<?>,V> - Class in reactor.core
Reactor.ReplyToEvent<T> - Class in reactor.core
reactor.support - package reactor.support
reactor.timer - package reactor.timer
reactor.tuple - package reactor.tuple: Tuples provide a type-safe way to specify multiple parameters.
reactor.util - package reactor.util
ReactorConfiguration - Class in reactor.core.configuration: An encapsulation of configuration for Reactor
ReactorConfiguration(List<DispatcherConfiguration>, String, Properties) - Constructor for class reactor.core.configuration.ReactorConfiguration
Reactors - Class in reactor.core.spec: Base class to encapsulate commonly-used functionality around Reactors.
Reactors() - Constructor for class reactor.core.spec.Reactors
ReactorSpec - Class in reactor.core.spec: A helper class for configuring a new Reactor.
ReactorSpec() - Constructor for class reactor.core.spec.ReactorSpec
read() - Method in interface reactor.core.configuration.ConfigurationReader: Reads the configuration
read() - Method in class reactor.core.configuration.PropertiesConfigurationReader
read() - Method in class reactor.io.Buffer: Read a single byte from the underlying ByteBuffer.
read(byte[]) - Method in class reactor.io.Buffer: Read at least b.length bytes from the underlying ByteBuffer.
read(ByteBuffer) - Method in class reactor.io.Buffer
readChar() - Method in class reactor.io.Buffer: Read the next char from the underlying ByteBuffer.
readDouble() - Method in class reactor.io.Buffer: Read the next double from the underlying ByteBuffer.
readFloat() - Method in class reactor.io.Buffer: Read the next float from the underlying ByteBuffer.
readInt() - Method in class reactor.io.Buffer: Read the next int from the underlying ByteBuffer.
readLong() - Method in class reactor.io.Buffer: Read the next long from the underlying ByteBuffer.
readOnly() - Method in class reactor.event.Event.Headers: Get the headers as a read-only version
readShort() - Method in class reactor.io.Buffer: Read the next short from the underlying ByteBuffer.
readType(Buffer) - Method in class reactor.io.encoding.SerializationCodec
ready() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Check whether the current Registration is ready for execution
reason() - Method in class reactor.core.composable.Promise: Return the error (if any) that has completed this Promise.
receive(Selector, Function<E, V>) - Method in interface reactor.core.Observable: Assign a Function to receive an Event and produce a reply of the given type.
receive(Selector, Function<E, V>) - Method in class reactor.core.Reactor
Recyclable - Interface in reactor.alloc: A simple interface that marks an object as being recyclable.
RecyclableNumber - Class in reactor.alloc
RecyclableNumber() - Constructor for class reactor.alloc.RecyclableNumber
RecyclableString - Class in reactor.alloc
RecyclableString() - Constructor for class reactor.alloc.RecyclableString
recycle() - Method in interface reactor.alloc.Recyclable: Free any internal resources and reset the state of the object to enable reuse.
recycle() - Method in class reactor.alloc.RecyclableNumber
recycle() - Method in class reactor.alloc.RecyclableString
recycle() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
recycle() - Method in class reactor.event.Event
recycle() - Method in class reactor.io.Buffer
reduce(Function<Tuple2<T, A>, A>, A) - Method in class reactor.core.composable.Stream: Reduce the values passing through this Stream into an object A.
reduce(Function<Tuple2<T, A>, A>, Supplier<A>, int) - Method in class reactor.core.composable.Stream: Reduce the values passing through this Stream into an object A.
reduce(Function<Tuple2<T, A>, A>) - Method in class reactor.core.composable.Stream: Reduce the values passing through this Stream into an object A.
ReduceAction<T,A> - Class in reactor.core.action
ReduceAction(int, Supplier<A>, Function<Tuple2<T, A>, A>, Observable, Object, Object) - Constructor for class reactor.core.action.ReduceAction
Reference<T extends Recyclable> - Interface in reactor.alloc: A Reference provides access to and metadata about a poolable object.
ReferenceCountingAllocator<T extends Recyclable> - Class in reactor.alloc: An implementation of Allocator that uses reference counting to determine when an object should be recycled and placed back into the pool to be reused.
ReferenceCountingAllocator(Supplier<T>) - Constructor for class reactor.alloc.ReferenceCountingAllocator
ReferenceCountingAllocator(int, Supplier<T>) - Constructor for class reactor.alloc.ReferenceCountingAllocator
regex(String) - Static method in class reactor.event.selector.Selectors: Creates a Selector based on the given regular expression.
RegexSelector - Class in reactor.event.selector: A Selector implementation based on the given regular expression.
RegexSelector(String) - Constructor for class reactor.event.selector.RegexSelector: Create a Selector when the given regex pattern.
regexSelector(String) - Static method in class reactor.event.selector.RegexSelector: Creates a Selector based on the given regular expression.
register(Selector, V) - Method in class reactor.event.registry.CachingRegistry
register(Selector, V) - Method in interface reactor.event.registry.Registry: Assign the given Selector with the given object.
Registration<T> - Interface in reactor.event.registry: A Registration represents an object that has been registered with a Registry.
Registry<T> - Interface in reactor.event.registry: Implementations of this interface manage a registry of objects that works sort of like a Map, except Registries don't use simple keys, they use Selectors to map their objects.
release() - Method in class reactor.alloc.AbstractReference
release(int) - Method in class reactor.alloc.AbstractReference
release(List<Reference<T>>) - Method in interface reactor.alloc.Allocator: Efficiently release a batch of References all at once.
release(List<Reference<T>>) - Method in class reactor.alloc.PartitionedAllocator
release() - Method in interface reactor.alloc.Reference: Decrease the reference count by 1.
release(int) - Method in interface reactor.alloc.Reference: Decrease the reference count by incr amount.
release(List<Reference<T>>) - Method in class reactor.alloc.ReferenceCountingAllocator
release(List<Reference<T>>) - Method in class reactor.alloc.RingBufferAllocator
release(List<Reference<Buffer>>) - Method in class reactor.io.BufferAllocator
remaining() - Method in class reactor.alloc.factory.BatchFactorySupplier: How many unallocated items remain in the pool.
remaining() - Method in class reactor.io.Buffer: How many bytes available in this Buffer.
remove(Consumer<T>) - Method in class reactor.function.support.DelegatingConsumer: Remove the given Consumer from the list of delegates.
remove(Collection<Consumer<T>>) - Method in class reactor.function.support.DelegatingConsumer: Remove the given Consumers from the list of delegates.
remove() - Method in class reactor.queue.IndexedChronicleQueuePersistor
remove() - Method in class reactor.queue.InMemoryQueuePersistor
remove() - Method in interface reactor.queue.QueuePersistor: Returns a Supplier that will simply remove the oldest item from the persistence queue.
remove(Object) - Method in class reactor.util.LinkedCaseInsensitiveMap
remove(Object) - Method in class reactor.util.LinkedMultiValueMap
removeDispatcher(String) - Method in class reactor.core.Environment: Removes the Dispatcher, stored using the given name from the environment.
removeDuplicateStrings(String[]) - Static method in class reactor.util.StringUtils: Remove duplicate Strings from the given array.
replace(String, String, String) - Static method in class reactor.util.StringUtils: Replace all occurrences of a substring within a string with another string.
Resequencer<T> - Class in reactor.function.support: A Resequencer allows claimants to ensure proper ordering of replies by allocating long values from a counter.
Resequencer(Consumer<T>) - Constructor for class reactor.function.support.Resequencer: Create a Resequencer that delegates to the given Consumer.
Resequencer(Consumer<T>, long) - Constructor for class reactor.function.support.Resequencer: Create a Resequencer that delegates to the given Consumer.
reset() - Method in class reactor.io.Buffer: Reset the buffer to the previously-saved position and limit.
reset() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Reset the Registration
resolve(Object) - Method in interface reactor.event.selector.HeaderResolver: Resolve the headers that might be encoded in a key.
resolveArgType(Consumer<?>) - Static method in class reactor.event.routing.ArgumentConvertingConsumerInvoker: Resolves the type of argument that can be accepted by the given consumer.
respondsToKey(Object) - Method in interface reactor.core.Observable: Are there any Registrations with Selectors that match the given key.
respondsToKey(Object) - Method in class reactor.core.Reactor
resume() - Method in class reactor.core.action.WindowAction
resume() - Method in interface reactor.event.lifecycle.Pausable: Unpause this Pausable.
resume() - Method in class reactor.event.registry.CachableRegistration
resume() - Method in interface reactor.event.registry.Registration: Unpause this Registration, making it available for selection.
resume() - Method in class reactor.function.support.Poller: Resume polling values from the Supplier.
resume() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Resume current Registration
retain() - Method in class reactor.alloc.AbstractReference
retain(int) - Method in class reactor.alloc.AbstractReference
retain() - Method in interface reactor.alloc.Reference: Increase reference count by 1.
retain(int) - Method in interface reactor.alloc.Reference: Increase reference count by incr amount.
rewind() - Method in class reactor.io.Buffer: Rewind this Buffer to the beginning.
rewind(int) - Method in class reactor.io.Buffer: Rewinds this buffer by len bytes.
RING_BUFFER - Static variable in class reactor.core.Environment: The name of the default ring buffer dispatcher
RingBufferAllocator<T extends Recyclable> - Class in reactor.alloc: An Allocator implementation based int the LMAX Disruptor RingBuffer.
RingBufferAllocator(String, int, Supplier<T>) - Constructor for class reactor.alloc.RingBufferAllocator
RingBufferAllocator(String, int, Supplier<T>, int) - Constructor for class reactor.alloc.RingBufferAllocator
RingBufferAllocator(String, int, Supplier<T>, int, EventHandler<Reference<T>>, ExceptionHandler, ProducerType, WaitStrategy, ExecutorService) - Constructor for class reactor.alloc.RingBufferAllocator
RingBufferAllocatorSpec<T extends Recyclable> - Class in reactor.alloc.spec: Helper class for creating a RingBufferAllocator.
RingBufferAllocatorSpec() - Constructor for class reactor.alloc.spec.RingBufferAllocatorSpec
RingBufferDispatcher - Class in reactor.event.dispatch: Implementation of a Dispatcher that uses a RingBuffer to queue tasks to execute.
RingBufferDispatcher(String) - Constructor for class reactor.event.dispatch.RingBufferDispatcher: Creates a new RingBufferDispatcher with the given name.
RingBufferDispatcher(String, int, Consumer<Throwable>, ProducerType, WaitStrategy) - Constructor for class reactor.event.dispatch.RingBufferDispatcher: Creates a new RingBufferDispatcher with the given name.
ringSize(int) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: Size of the RingBuffer ring.
roundRobin(T...) - Static method in class reactor.function.Suppliers: Create a Supplier that continually round-robin load balances each call to Supplier.get() by iterating over the objects.
roundRobinEventRouting() - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's EventRouter to route events to one consumer selected from the matching consumers using a round-robin algorithm consumers
RoundRobinFilter - Class in reactor.filter: A Filter implementation that returns a single item.
RoundRobinFilter() - Constructor for class reactor.filter.RoundRobinFilter
route(AbstractLifecycleDispatcher.Task) - Static method in class reactor.event.dispatch.AbstractLifecycleDispatcher
route(Object, Event<?>, List<Registration<? extends Consumer<? extends Event<?>>>>, Consumer<?>, Consumer<Throwable>) - Method in class reactor.event.routing.ConsumerFilteringEventRouter
route(Object, Event<?>, List<Registration<? extends Consumer<? extends Event<?>>>>, Consumer<?>, Consumer<Throwable>) - Method in interface reactor.event.routing.EventRouter: Routes the event, triggered by a notification with the given key to the consumers.
route(Object, Event<?>, List<Registration<? extends Consumer<? extends Event<?>>>>, Consumer<?>, Consumer<Throwable>) - Method in class reactor.event.routing.TraceableDelegatingEventRouter
run() - Method in class reactor.event.dispatch.AbstractMultiThreadDispatcher.MultiThreadTask
run() - Method in class reactor.event.dispatch.AbstractSingleThreadDispatcher.SingleThreadTask
run() - Method in class reactor.timer.HashWheelTimer.TimerRegistration: Run the delegate of the current Registration

S

scan(Function<Tuple2<T, A>, A>, A) - Method in class reactor.core.composable.Stream: Scan the values passing through this Stream into an object A.
scan(Function<Tuple2<T, A>, A>, Supplier<A>) - Method in class reactor.core.composable.Stream: Scan the values passing through this Stream into an object A.
scan(Function<Tuple2<T, A>, A>) - Method in class reactor.core.composable.Stream: Scan the values passing through this Stream into an object A.
ScanAction<T,A> - Class in reactor.core.action
ScanAction(Supplier<A>, Function<Tuple2<T, A>, A>, Observable, Object, Object) - Constructor for class reactor.core.action.ScanAction
schedule(Consumer<T>, T) - Method in class reactor.core.Reactor: Schedule an arbitrary Consumer to be executed on the current Reactor Dispatcher, passing the given .
schedule(Consumer<T>, T, Observable) - Static method in class reactor.core.spec.Reactors: Deprecated.
@since 1.1
schedule(Consumer<Long>, long, TimeUnit, long) - Method in class reactor.timer.HashWheelTimer
schedule(Consumer<Long>, long, TimeUnit) - Method in class reactor.timer.HashWheelTimer
schedule(Consumer<Long>, long, TimeUnit, long) - Method in class reactor.timer.SimpleHashWheelTimer
schedule(Consumer<Long>, long, TimeUnit) - Method in class reactor.timer.SimpleHashWheelTimer
schedule(Consumer<Long>, long, TimeUnit, long) - Method in interface reactor.timer.Timer: Schedule a recurring task.
schedule(Consumer<Long>, long, TimeUnit) - Method in interface reactor.timer.Timer: Schedule a recurring task.
select(Object) - Method in class reactor.event.registry.CachingRegistry
select(Object) - Method in interface reactor.event.registry.Registry: Select Registrations whose Selector Selector.matches(Object) the given key.
Selector - Interface in reactor.event.selector: A Selector is a wrapper around an arbitrary object.
Selectors - Class in reactor.event.selector: Helper methods for creating Selectors.
Selectors() - Constructor for class reactor.event.selector.Selectors
Selectors.AnonymousKey - Class in reactor.event.selector
send(Object, E) - Method in interface reactor.core.Observable: Notify this component of the given Event and register an internal Consumer that will take the output of a previously-registered Function and respond using the key set on the Event's replyTo property.
send(Object, S) - Method in interface reactor.core.Observable: Notify this component that the given Supplier will provide an Event and register an internal Consumer that will take the output of a previously-registered Function and respond using the key set on the Event's replyTo property.
send(Object, E, Observable) - Method in interface reactor.core.Observable: Notify this component of the given Event and register an internal Consumer that will take the output of a previously-registered Function and respond to the key set on the Event's replyTo property and will call the notify method on the given Observable.
send(Object, S, Observable) - Method in interface reactor.core.Observable: Notify this component that the given Supplier will provide an Event and register an internal Consumer that will take the output of a previously-registered Function and respond to the key set on the Event's replyTo property and will call the notify method on the given Observable.
send(Object, E) - Method in class reactor.core.Reactor
send(Object, S) - Method in class reactor.core.Reactor
send(Object, E, Observable) - Method in class reactor.core.Reactor
send(Object, S, Observable) - Method in class reactor.core.Reactor
sendAndReceive(Object, REQ, Consumer<RESP>) - Method in interface reactor.core.Observable: Register the given Consumer on an anonymous Selector and set the given event's replyTo property to the corresponding anonymous key, then register the consumer to receive replies from the Function assigned to handle the given key.
sendAndReceive(Object, S, Consumer<RESP>) - Method in interface reactor.core.Observable: Register the given Consumer on an anonymous Selector and set the event's replyTo property to the corresponding anonymous key, then register the consumer to receive replies from the Function assigned to handle the given key.
sendAndReceive(Object, REQ, Consumer<RESP>) - Method in class reactor.core.Reactor
sendAndReceive(Object, S, Consumer<RESP>) - Method in class reactor.core.Reactor
SerializationCodec<E,IN,OUT> - Class in reactor.io.encoding: Abstract base class for Codec Codecs that perform serialization of objects.
SerializationCodec(E, boolean) - Constructor for class reactor.io.encoding.SerializationCodec: Create a SerializationCodec using the given engine and specifying whether or not to prepend a length field to frame the message.
serializer(ObjectMapper) - Method in class reactor.io.encoding.json.JacksonJsonCodec
serializer(Kryo) - Method in class reactor.io.encoding.kryo.KryoCodec
serializer(Map<Class<?>, Message>) - Method in class reactor.io.encoding.protobuf.ProtobufCodec
serializer(E) - Method in class reactor.io.encoding.SerializationCodec
set(String, V) - Method in class reactor.event.Event.Headers: Set the header value.
set(K, V) - Method in class reactor.util.LinkedMultiValueMap
set(K, V) - Method in interface reactor.util.MultiValueMap: Set the given single value under the given key.
setAll(Map<String, Object>) - Method in class reactor.event.Event.Headers: Sets all of the headers represented by entries in the given headers Map.
setAll(Map<K, V>) - Method in class reactor.util.LinkedMultiValueMap
setAll(Map<K, V>) - Method in interface reactor.util.MultiValueMap: Set the given values under.
setCompletionConsumer(Consumer<?>) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
setConsumerRegistry(Registry<Consumer<? extends Event<?>>>) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
setData(T) - Method in class reactor.event.Event: Set the internal data to wrap.
setErrorConsumer(Consumer<Throwable>) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
setEvent(Event<?>) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
setEventRouter(EventRouter) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
setId(ID) - Method in interface reactor.support.Identifiable
setKey(Object) - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
setKey(Object) - Method in class reactor.event.Event: Set the key this event is being notified with.
setMembership(Set) - Static method in class reactor.event.selector.Selectors: Creates a Selector that matches objects on set membership.
SetMembershipSelector - Class in reactor.event.selector: Implementation of Selector that matches objects on set membership.
SetMembershipSelector(Set) - Constructor for class reactor.event.selector.SetMembershipSelector: Create a Selector when the given regex pattern.
setOrigin(UUID) - Method in class reactor.event.Event.Headers: Set the origin header.
setOrigin(String) - Method in class reactor.event.Event.Headers: Set the origin header.
setReplyTo(Object) - Method in class reactor.event.Event: Set the key that interested parties should send replies to.
setTimer(Timer) - Static method in class reactor.timer.TimeUtils
setValue(int) - Method in class reactor.alloc.RecyclableNumber
setValue(long) - Method in class reactor.alloc.RecyclableNumber
setValue(float) - Method in class reactor.alloc.RecyclableNumber
setValue(double) - Method in class reactor.alloc.RecyclableNumber
setValue(String) - Method in class reactor.alloc.RecyclableString
shutdown() - Method in class reactor.alloc.RingBufferAllocator
shutdown() - Method in class reactor.core.Environment: Shuts down this Environment, causing all of its Dispatchers to be shut down.
shutdown() - Method in class reactor.core.processor.Processor: Shutdown this Processor by shutting down the thread pool.
shutdown() - Method in class reactor.event.dispatch.AbstractLifecycleDispatcher
shutdown() - Method in class reactor.event.dispatch.ActorDispatcher
shutdown() - Method in interface reactor.event.dispatch.Dispatcher: Shutdown this Dispatcher such that it can no longer be used.
shutdown() - Method in class reactor.event.dispatch.RingBufferDispatcher
shutdown() - Method in class reactor.event.dispatch.SynchronousDispatcher
shutdown() - Method in class reactor.event.dispatch.ThreadPoolExecutorDispatcher
shutdown() - Method in class reactor.event.dispatch.TraceableDelegatingDispatcher
shutdown() - Method in class reactor.event.dispatch.WorkQueueDispatcher
shutdown() - Method in class reactor.function.support.Poller: Shutdown this Poller and stop the internal thread from polling the supplier.
signalAllWhenBlocking() - Method in class reactor.event.dispatch.ParkWaitStrategy
SimpleHashWheelTimer - Class in reactor.timer: A hashed wheel timer implementation that uses a Registry and custom Selectors to determine when tasks should be executed.
SimpleHashWheelTimer() - Constructor for class reactor.timer.SimpleHashWheelTimer: Create a new SimpleHashWheelTimer using the default resolution of 50ms.
SimpleHashWheelTimer(int) - Constructor for class reactor.timer.SimpleHashWheelTimer: Create a new SimpleHashWheelTimer using the given timer resolution.
SimpleMethodNotificationKeyResolver - Class in reactor.core.dynamic.reflect: An implementation of MethodNotificationKeyResolver that looks for an Notify annotation or uses the method name minus the "notify" portion and lower-casing the first character.
SimpleMethodNotificationKeyResolver() - Constructor for class reactor.core.dynamic.reflect.SimpleMethodNotificationKeyResolver
SimpleMethodSelectorResolver - Class in reactor.core.dynamic.reflect: An implementation of MethodSelectorResolver that looks for an On annotation or uses the method name minus the "on" portion and lower-casing the first character.
SimpleMethodSelectorResolver() - Constructor for class reactor.core.dynamic.reflect.SimpleMethodSelectorResolver
simplePredicate - Static variable in class reactor.core.action.FilterAction
singleThreadedProducer() - Method in class reactor.core.processor.spec.ProcessorSpec: Optimize for highest throughput by assuming only a single thread will be publishing data events into this Processor.
SingleThreadTask() - Constructor for class reactor.event.dispatch.AbstractSingleThreadDispatcher.SingleThreadTask
SingleUseConsumer<T> - Class in reactor.function.support: A Consumer implementation that allows the delegate Consumer to only be called once.
SingleUseConsumer() - Constructor for class reactor.function.support.SingleUseConsumer: Used to create anonymous subclasses.
SingleUseConsumer(Consumer<T>) - Constructor for class reactor.function.support.SingleUseConsumer: Create a single-use Consumer using the given delgate.
size() - Method in class reactor.alloc.factory.BatchFactorySupplier: Returns the number of items being pooled.
size() - Method in class reactor.queue.IndexedChronicleQueuePersistor
size() - Method in class reactor.queue.InMemoryQueuePersistor
size() - Method in class reactor.queue.PersistentQueue
size() - Method in interface reactor.queue.QueuePersistor: Get the number of items persisted right now.
size - Variable in class reactor.tuple.Tuple
size() - Method in class reactor.tuple.Tuple: Return the number of elements in this Tuple.
size() - Method in class reactor.util.LinkedMultiValueMap
skip(int) - Method in class reactor.io.Buffer: Skips len bytes.
sleepingWaitStrategy() - Method in class reactor.core.processor.spec.ProcessorSpec: Set SleepingWaitStrategy as wait strategy.
SleepWait() - Constructor for class reactor.timer.HashWheelTimer.SleepWait
slice(int, int) - Method in class reactor.io.Buffer: Create a copy of the given range.
slice(int...) - Method in class reactor.io.Buffer: Slice this buffer at the given positions.
SMALL_BUFFER_SIZE - Static variable in class reactor.io.Buffer: The size, in bytes, of a small buffer.
SnappyCodec<IN,OUT> - Class in reactor.io.encoding.compress
SnappyCodec(Codec<Buffer, IN, OUT>) - Constructor for class reactor.io.encoding.compress.SnappyCodec
snapshot() - Method in class reactor.io.Buffer: Save the current buffer position and limit.
sortStringArray(String[]) - Static method in class reactor.util.StringUtils: Turn given source String array into sorted array.
split() - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be each element E of any Iterable flowing this Stream
split(int) - Method in class reactor.core.composable.Stream: Create a new Stream whose values will be each element E of any Iterable flowing this Stream
split(int) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter.
split(List<Buffer.View>, int) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter but save memory by reusing the given List.
split(int, boolean) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter and optionally leave the delimiter intact rather than stripping it.
split(List<Buffer.View>, int, boolean) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter, save memory by reusing the given List, and optionally leave the delimiter intact rather than stripping it.
split(Buffer) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter and leave the delimiter on the end of each segment.
split(Buffer, boolean) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter.
split(List<Buffer.View>, Buffer, boolean) - Method in class reactor.io.Buffer: Split this buffer on the given delimiter.
split(String, String) - Static method in class reactor.util.StringUtils: Split a String at the first occurrence of the delimiter.
splitArrayElementsIntoProperties(String[], String) - Static method in class reactor.util.StringUtils: Take an array Strings and split each element based on the given delimiter.
splitArrayElementsIntoProperties(String[], String, String) - Static method in class reactor.util.StringUtils: Take an array Strings and split each element based on the given delimiter.
StandardCodecs - Class in reactor.io.encoding: A selection of standard codecs.
StandardConverters - Class in reactor.convert
StandardConverters() - Constructor for class reactor.convert.StandardConverters
StandardConverters.ConstructorParameterConverter - Enum in reactor.convert: A Converter that will convert to the target type by creating a new instance of the target type using the source, or a conversion of the source, as the argument that's passed to the target type's constructor.
StandardConverters.StringToNumberConverter - Enum in reactor.convert: A Converter that will convert a String to a Number.
StandardConverters.ToStringConverter - Enum in reactor.convert: A Converter that will convert any Object to a String by calling its toString method.
start() - Method in class reactor.alloc.RingBufferAllocator
start() - Method in interface reactor.function.batch.BatchConsumer: Called when a batch begins.
start() - Method in class reactor.function.support.DelegatingConsumer
start() - Method in class reactor.timer.HashWheelTimer: Start the Timer
startsWithIgnoreCase(String, String) - Static method in class reactor.util.StringUtils: Test if the given String starts with the specified prefix, ignoring upper/lower case.
state(boolean, String) - Static method in class reactor.util.Assert: Assert a boolean expression, throwing IllegalStateException if the test result is false.
state(boolean) - Static method in class reactor.util.Assert: Assert a boolean expression, throwing IllegalStateException if the test result is false.
STATUS_CANCELLED - Static variable in class reactor.timer.HashWheelTimer.TimerRegistration
STATUS_PAUSED - Static variable in class reactor.timer.HashWheelTimer.TimerRegistration
STATUS_READY - Static variable in class reactor.timer.HashWheelTimer.TimerRegistration
Stream<T> - Class in reactor.core.composable: A Stream is a stateless event processor that provides methods for attaching Consumers to consume the values passing through the stream.
Stream(Observable, int, Composable<?>, Environment) - Constructor for class reactor.core.composable.Stream: Create a new Stream that will use the Observable to pass its values to registered handlers.
Stream(Observable, int, Composable<?>, Tuple2<Selector, Object>, Environment) - Constructor for class reactor.core.composable.Stream: Create a new Stream that will use the Observable to pass its values to registered handlers.
Streams - Class in reactor.core.composable.spec: A public factory to build Streams that use a SynchronousDispatcher.
Streams() - Constructor for class reactor.core.composable.spec.Streams
StreamSpec<T> - Class in reactor.core.composable.spec: A helper class for specifying a bounded Stream.
StreamSpec() - Constructor for class reactor.core.composable.spec.StreamSpec
STRING_CODEC - Static variable in class reactor.io.encoding.StandardCodecs: A StringCodec.
StringCodec - Class in reactor.io.encoding
StringCodec() - Constructor for class reactor.io.encoding.StringCodec
StringUtils - Class in reactor.util: Miscellaneous String utility methods.
StringUtils() - Constructor for class reactor.util.StringUtils
stripFilenameExtension(String) - Static method in class reactor.util.StringUtils: Strip the filename extension from the given path, e.g.
submit() - Method in class reactor.core.fork.ForkJoinTask: Submit all configured tasks, possibly in parallel (depending on the configuration of the Executor in use), passing null as an input parameter.
submit(V) - Method in class reactor.core.fork.ForkJoinTask: Submit all configured tasks, possibly in parallel (depending on the configuration of the Executor in use), passing arg as an input parameter.
submit(Consumer<Long>, long, TimeUnit) - Method in class reactor.timer.HashWheelTimer
submit(Consumer<Long>) - Method in class reactor.timer.HashWheelTimer
submit(Consumer<Long>, long, TimeUnit) - Method in class reactor.timer.SimpleHashWheelTimer
submit(Consumer<Long>) - Method in class reactor.timer.SimpleHashWheelTimer
submit(Consumer<Long>, long, TimeUnit) - Method in interface reactor.timer.Timer: Submit a task for arbitrary execution after the given time delay.
submit(Consumer<Long>) - Method in interface reactor.timer.Timer: Submit a task for arbitrary execution after the delay of this timer's resolution.
substring(int, int) - Method in class reactor.io.Buffer: Slice a portion of this buffer and convert it to a String.
substringMatch(CharSequence, int, CharSequence) - Static method in class reactor.util.StringUtils: Test whether the given string matches the given substring at the given index.
success(T) - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise and use the given value to complete the Promise immediately.
success(T) - Method in class reactor.core.composable.spec.PromiseSpec: Configures the promise to have been successfully completed with the given value.
supplier(T) - Static method in class reactor.function.Functions: Creates a Supplier that will always return the given value.
supplier(Class<T>) - Static method in class reactor.function.Functions: Creates a Supplier that will return a new instance of type each time it's called.
supplier(Callable<T>) - Static method in class reactor.function.Functions: Creates a Supplier that will call the callable each time it's asked for a value.
supplier(Future<T>) - Static method in class reactor.function.Functions: Creates a Supplier that will get its value from the future each time it's asked for a value.
Supplier<T> - Interface in reactor.function: Implementations of this class supply the caller with an object.
Suppliers - Class in reactor.function: Helper class for working tying Suppliers to Iterables and other types of collections.
supply(Supplier<T>) - Method in class reactor.core.composable.spec.PromiseSpec: Configures the promise to have been successfully completed with the value from the given valueSupplier.
supply(T) - Static method in class reactor.function.Suppliers: Wrap the given object that will supply the given object every time Supplier.get() is called.
SupplyAction<T> - Class in reactor.core.action
SupplyAction(Supplier<T>, Observable, Object, Object) - Constructor for class reactor.core.action.SupplyAction
supplyOnce(T) - Static method in class reactor.function.Suppliers: Supply the given object only once, the first time Supplier.get() is invoked.
supplyWhile(T, Predicate<T>) - Static method in class reactor.function.Suppliers: Supply the given object to callers only as long as the given Predicate returns true.
supports(Method) - Method in class reactor.core.dynamic.reflect.SimpleMethodNotificationKeyResolver
supports(Method) - Method in class reactor.core.dynamic.reflect.SimpleMethodSelectorResolver
supports(Consumer<?>) - Method in class reactor.event.routing.ArgumentConvertingConsumerInvoker
Supports<T> - Interface in reactor.support: Simple interface that can be applied to components to determine whether or not they support a particular type of use.
supports(T) - Method in interface reactor.support.Supports: Implementations should decided whether they support the given object or not.
synchronousDispatcher() - Method in class reactor.core.spec.support.DispatcherComponentSpec: Configures the component to use a synchronous dispatcher
SynchronousDispatcher - Class in reactor.event.dispatch: A Dispatcher implementation that dispatches events using the calling thread.
SynchronousDispatcher() - Constructor for class reactor.event.dispatch.SynchronousDispatcher

T

T(Class<?>) - Static method in class reactor.event.selector.Selectors: A short-hand alias for Selectors.type(Class).
tap() - Method in class reactor.core.composable.Stream: Create a Tap that maintains a reference to the last value seen by this Stream.
Tap<T> - Class in reactor.function.support: A Tap provides a limited window into an event stream.
Tap() - Constructor for class reactor.function.support.Tap: Create a Tap.
task(Supplier<T>) - Static method in class reactor.core.composable.spec.Promises: Create a Deferred backed by a Promise and producing the value for the Promise using the given supplier.
Task() - Constructor for class reactor.event.dispatch.AbstractLifecycleDispatcher.Task
test(T) - Method in interface reactor.function.Predicate: Returns true if the input object matches some criteria.
then(Consumer<T>, Consumer<Throwable>) - Method in class reactor.core.composable.Promise: Assign both a success Consumer and an optional (possibly null) error Consumer.
then(Function<T, V>, Consumer<Throwable>) - Method in class reactor.core.composable.Promise: Assign a success Function that will either be invoked later, when the Promise is successfully completed with a value, or, if this Promise has already been fulfilled, the function is immediately scheduled to be executed on the current Dispatcher.
THREAD_POOL - Static variable in class reactor.core.Environment: The name of the default thread pool dispatcher
ThreadPartitionedAllocator<T extends Recyclable> - Class in reactor.alloc
ThreadPartitionedAllocator(Supplier<T>) - Constructor for class reactor.alloc.ThreadPartitionedAllocator
ThreadPoolExecutorDispatcher - Class in reactor.event.dispatch: A Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events.
ThreadPoolExecutorDispatcher(int, int) - Constructor for class reactor.event.dispatch.ThreadPoolExecutorDispatcher: Creates a new ThreadPoolExecutorDispatcher with the given poolSize and backlog.
ThreadPoolExecutorDispatcher(int, int, String) - Constructor for class reactor.event.dispatch.ThreadPoolExecutorDispatcher: Create a new ThreadPoolExecutorDispatcher with the given size, backlog, name, and RejectedExecutionHandler.
ThreadPoolExecutorDispatcher(int, int, String, BlockingQueue<Runnable>, RejectedExecutionHandler) - Constructor for class reactor.event.dispatch.ThreadPoolExecutorDispatcher: Create a new ThreadPoolExecutorDispatcher with the given size, backlog, name, and RejectedExecutionHandler.
ThreadPoolExecutorDispatcher(int, int, ExecutorService) - Constructor for class reactor.event.dispatch.ThreadPoolExecutorDispatcher: Create a new ThreadPoolTaskExecutor with the given backlog and ExecutorService.
timeout(long) - Method in class reactor.core.composable.Composable: Flush the parent if any or the current composable otherwise when the last notification occurred before milliseconds.
timeout(long, Timer) - Method in class reactor.core.composable.Composable: Flush the parent if any or the current composable otherwise when the last notification occurred before milliseconds.
timeout(long) - Method in class reactor.core.composable.Promise
timeout(long, Timer) - Method in class reactor.core.composable.Promise
timeout(long, Timer) - Method in class reactor.core.composable.Stream
timeout(long) - Method in class reactor.core.composable.Stream
TIMEOUT_EVENT - Static variable in class reactor.core.action.TimeoutAction
TimeoutAction<T> - Class in reactor.core.action
TimeoutAction(Observable, Object, Object, Timer, long) - Constructor for class reactor.core.action.TimeoutAction
Timer - Interface in reactor.timer
TimerRegistration(long, long, T, long) - Constructor for class reactor.timer.HashWheelTimer.TimerRegistration: Creates a new Timer Registration with given , and .
TimeUtils - Class in reactor.timer
TimeUtils() - Constructor for class reactor.timer.TimeUtils
toArray() - Method in class reactor.tuple.Tuple: Turn this Tuple into a plain Object array.
toArray(Enumeration<E>, A[]) - Static method in class reactor.util.CollectionUtils: Marshal the elements from the given enumeration into an array of the given type.
toIterator(Enumeration<E>) - Static method in class reactor.util.CollectionUtils: Adapt an enumeration to an iterator.
tokenizeToStringArray(String, String) - Static method in class reactor.util.StringUtils: Tokenize the given String into a String array via a StringTokenizer.
tokenizeToStringArray(String, String, boolean, boolean) - Static method in class reactor.util.StringUtils: Tokenize the given String into a String array via a StringTokenizer.
toLanguageTag(Locale) - Static method in class reactor.util.StringUtils: Determine the RFC 3066 compliant language tag, as used for the HTTP "Accept-Language" header.
toMultiValueMap(Map<K, List<V>>) - Static method in class reactor.util.CollectionUtils: Adapts a Map<K, List<V>> to an MultiValueMap<K,V>.
toObjectArray(Object) - Static method in class reactor.util.ObjectUtils: Convert the given array (which may be a primitive array) to an object array (if necessary of primitive wrapper objects).
toSingleValueMap() - Method in class reactor.util.LinkedMultiValueMap
toSingleValueMap() - Method in interface reactor.util.MultiValueMap: Returns the first values contained in this MultiValueMap.
toString() - Method in class reactor.alloc.AbstractReference
toString() - Method in class reactor.alloc.RecyclableString
toString() - Method in class reactor.core.action.Action
toString() - Method in class reactor.core.action.ActionUtils.ActionVisitor
toString() - Method in class reactor.core.action.BatchAction
toString() - Method in class reactor.core.action.FlushableAction
toString() - Method in class reactor.core.composable.Promise
toString() - Method in class reactor.event.Event.Headers
toString() - Method in class reactor.event.Event
toString() - Method in class reactor.event.registry.CachableRegistration
toString() - Method in class reactor.event.selector.ObjectSelector
toString() - Method in class reactor.io.Buffer
toString() - Method in class reactor.timer.HashWheelTimer.TimerRegistration
toString() - Method in class reactor.timer.HashWheelTimer
toString() - Method in class reactor.util.LinkedMultiValueMap
toString() - Method in class reactor.util.PartitionedReferencePile
toStringArray(Collection<String>) - Static method in class reactor.util.StringUtils: Copy the given Collection into a String array.
toStringArray(Enumeration<String>) - Static method in class reactor.util.StringUtils: Copy the given Enumeration into a String array.
TraceableDelegatingDispatcher - Class in reactor.event.dispatch: An implementation of Dispatcher that traces activity through it.
TraceableDelegatingDispatcher(Dispatcher) - Constructor for class reactor.event.dispatch.TraceableDelegatingDispatcher
TraceableDelegatingEventRouter - Class in reactor.event.routing
TraceableDelegatingEventRouter(EventRouter) - Constructor for class reactor.event.routing.TraceableDelegatingEventRouter
TraceableDelegatingFilter - Class in reactor.filter
TraceableDelegatingFilter(Filter) - Constructor for class reactor.filter.TraceableDelegatingFilter
traceEventPath() - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures this component to provide event tracing when dispatching and routing an event.
traceEventPath(boolean) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures this component to provide or not provide event tracing when dispatching and routing an event.
trimAllWhitespace(String) - Static method in class reactor.util.StringUtils: Trim all whitespace from the given String: leading, trailing, and inbetween characters.
trimArrayElements(String[]) - Static method in class reactor.util.StringUtils: Trim the elements of the given String array, calling String.trim() on each of them.
trimLeadingCharacter(String, char) - Static method in class reactor.util.StringUtils: Trim all occurrences of the supplied leading character from the given String.
trimLeadingWhitespace(String) - Static method in class reactor.util.StringUtils: Trim leading whitespace from the given String.
trimTrailingCharacter(String, char) - Static method in class reactor.util.StringUtils: Trim all occurrences of the supplied trailing character from the given String.
trimTrailingWhitespace(String) - Static method in class reactor.util.StringUtils: Trim trailing whitespace from the given String.
trimWhitespace(String) - Static method in class reactor.util.StringUtils: Trim leading and trailing whitespace from the given String.
Tuple - Class in reactor.tuple: A Tuple is an immutable Collection of objects, each of which can be of an arbitrary type.
Tuple(Collection<Object>) - Constructor for class reactor.tuple.Tuple: Creates a new Tuple that holds the given values.
Tuple(Object...) - Constructor for class reactor.tuple.Tuple: Creates a new Tuple that holds the given values.
Tuple1<T1> - Class in reactor.tuple: A tuple that holds a single value
Tuple2<T1,T2> - Class in reactor.tuple: A tuple that holds two values
Tuple3<T1,T2,T3> - Class in reactor.tuple: A tuple that holds three values
Tuple4<T1,T2,T3,T4> - Class in reactor.tuple: A tuple that holds four values
Tuple5<T1,T2,T3,T4,T5> - Class in reactor.tuple: A tuple that holds five values
Tuple6<T1,T2,T3,T4,T5,T6> - Class in reactor.tuple: A tuple that holds six values
Tuple7<T1,T2,T3,T4,T5,T6,T7> - Class in reactor.tuple: A tuple that holds seven values
Tuple8<T1,T2,T3,T4,T5,T6,T7,T8> - Class in reactor.tuple: A tuple that holds eight values
TupleN<T1,T2,T3,T4,T5,T6,T7,T8,TRest extends Tuple> - Class in reactor.tuple: A tuple that holds 9 or more values
type(Class<?>) - Static method in class reactor.event.selector.Selectors: Creates a Selector based on the given class type that matches objects whose type is assignable according to Class.isAssignableFrom(Class).
TypeReference<T> - Interface in reactor.util: Marker interface to provide generic type information.
typeSelector(Class<?>) - Static method in class reactor.event.selector.ClassSelector: Creates a ClassSelector based on the given class type that only matches if the key being matched is assignable according to Class.isAssignableFrom(Class).
TypeUtils - Class in reactor.util
TypeUtils() - Constructor for class reactor.util.TypeUtils

U

U(String) - Static method in class reactor.event.selector.Selectors: A short-hand alias for Selectors.uri(String).
uncapitalize(String) - Static method in class reactor.util.StringUtils: Uncapitalize a String, changing the first letter to lower case as per Character.toLowerCase(char).
uncaughtErrorHandler(Consumer<Throwable>) - Method in class reactor.core.spec.support.EventRoutingComponentSpec: Configures the component's uncaught error handler for any errors that get reported into this component but aren't a direct result of dispatching (e.g.
unmodifiableMultiValueMap(MultiValueMap<? extends K, ? extends V>) - Static method in class reactor.util.CollectionUtils: Returns an unmodifiable view of the specified multi-value map.
unqualify(String) - Static method in class reactor.util.StringUtils: Unqualify a string qualified by a '.' dot character.
unqualify(String, char) - Static method in class reactor.util.StringUtils: Unqualify a string qualified by a separator character.
unregister(Object) - Method in class reactor.event.registry.CachingRegistry
unregister(Object) - Method in interface reactor.event.registry.Registry: Remove any objects matching this key.
uri(String) - Static method in class reactor.event.selector.Selectors: Creates a Selector based on a URI template.
UriPathSelector - Class in reactor.event.selector: A Selector implementation based on a UriPathTemplate.
UriPathSelector(String) - Constructor for class reactor.event.selector.UriPathSelector: Create a selector from the given uri template string.
uriPathSelector(String) - Static method in class reactor.event.selector.UriPathSelector: Creates a Selector based on a URI template.
UriPathTemplate - Class in reactor.event.selector: Represents a URI template.
UriPathTemplate(String) - Constructor for class reactor.event.selector.UriPathTemplate: Creates a new UriPathTemplate from the given uriPattern.
UriSelector - Class in reactor.event.selector: A Selector implementation that matches on various components of a full URI.
UriSelector(String) - Constructor for class reactor.event.selector.UriSelector
UriSelector(URI) - Constructor for class reactor.event.selector.UriSelector
UriUtils - Class in reactor.function.support: Utility class for URI encoding and decoding based on RFC 3986.
UriUtils() - Constructor for class reactor.function.support.UriUtils
UUIDUtils - Class in reactor.util: Helper for creating random and Type 1 (time-based) UUIDs.

V

valueAccepted(T) - Method in class reactor.core.composable.Promise
valueOf(String) - Static method in enum reactor.convert.StandardConverters.ConstructorParameterConverter: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.convert.StandardConverters.StringToNumberConverter: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.convert.StandardConverters.ToStringConverter: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.core.configuration.DispatcherType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.core.spec.support.EventRoutingComponentSpec.EventRoutingStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.io.encoding.FrameCodec.LengthField: Returns the enum constant of this type with the specified name.
values() - Static method in enum reactor.convert.StandardConverters.ConstructorParameterConverter: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.convert.StandardConverters.StringToNumberConverter: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.convert.StandardConverters.ToStringConverter: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.core.configuration.DispatcherType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.core.spec.support.EventRoutingComponentSpec.EventRoutingStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.io.encoding.FrameCodec.LengthField: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class reactor.util.LinkedMultiValueMap

W

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class reactor.event.dispatch.ParkWaitStrategy
waitStrategy(WaitStrategy) - Method in class reactor.alloc.spec.RingBufferAllocatorSpec: Specify the WaitStrategy to use (defaults to BlockingWaitStrategy).
waitStrategy(WaitStrategy) - Method in class reactor.core.processor.spec.ProcessorSpec: Set Disruptor's WaitStrategy.
waitUntil(long) - Method in class reactor.timer.HashWheelTimer.BusySpinWait
waitUntil(long) - Method in class reactor.timer.HashWheelTimer.SleepWait
waitUntil(long) - Method in interface reactor.timer.HashWheelTimer.WaitStrategy: Wait until the given deadline,
waitUntil(long) - Method in class reactor.timer.HashWheelTimer.YieldingWait
when(Class<E>, Consumer<E>) - Method in class reactor.core.composable.Composable: Assign an error handler to exceptions of the given type.
when(Class<E>, Consumer<E>) - Method in class reactor.core.composable.Promise
when(Promise<T>...) - Static method in class reactor.core.composable.spec.Promises: Merge given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.
when(Deferred<T, Promise<T>>...) - Static method in class reactor.core.composable.spec.Promises: Merge given deferred promises into a new a Promise that will be fulfilled when all of the given Deferred Deferreds have been fulfilled.
when(Collection<? extends Promise<T>>) - Static method in class reactor.core.composable.spec.Promises: Aggregate given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.
when(Class<E>, Consumer<E>) - Method in class reactor.core.composable.Stream
when(Class<? extends Throwable>, Consumer<Throwable>) - Method in class reactor.core.processor.spec.ProcessorSpec: Assign the given Consumer as an error handler for exceptions of the given type.
WhenAction<T> - Class in reactor.core.action
WhenAction(Predicate<T>, Observable, Object, Object) - Constructor for class reactor.core.action.WhenAction
window(int) - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed into the returned Stream every specified time from the in milliseconds.
window(int, TimeUnit) - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed into the returned Stream every specified time from the and a .
window(int, TimeUnit, int) - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed into the returned Stream every specified time from the , after an initial in milliseconds.
window(int, TimeUnit, int, Timer) - Method in class reactor.core.composable.Stream: Collect incoming values into a List that will be pushed into the returned Stream every specified time from the , after an initial in milliseconds.
WindowAction<T> - Class in reactor.core.action: WindowAction is collecting events on a steam until is reached, after that streams collected events further, clears the internal collection and starts collecting items from empty list.
WindowAction(Observable, Object, Object, Timer, int, TimeUnit, int) - Constructor for class reactor.core.action.WindowAction
WORK_QUEUE - Static variable in class reactor.core.Environment: The name of the default work queue dispatcher
WorkQueueDispatcher - Class in reactor.event.dispatch: Implementation of a Dispatcher that uses a multi-threaded, multi-producer RingBuffer to queue tasks to execute.
WorkQueueDispatcher(String, int, int, Consumer<Throwable>) - Constructor for class reactor.event.dispatch.WorkQueueDispatcher
WorkQueueDispatcher(String, int, int, Consumer<Throwable>, ProducerType, WaitStrategy) - Constructor for class reactor.event.dispatch.WorkQueueDispatcher
wrap(T) - Static method in class reactor.event.Event: Wrap the given object with an Event.
wrap(T, Object) - Static method in class reactor.event.Event: Wrap the given object with an Event and set the replyTo to the given replyToKey.
wrap(byte[]) - Static method in class reactor.io.Buffer: Convenience method to create a new, fixed-length Buffer and putting the given byte array into the buffer.
wrap(String, boolean) - Static method in class reactor.io.Buffer: Convenience method to create a new Buffer from the given String and optionally specify whether the new Buffer should be a fixed length or not.
wrap(String) - Static method in class reactor.io.Buffer: Convenience method to create a new, fixed-length Buffer from the given String.
write(ByteBuffer) - Method in class reactor.io.Buffer

X

xor(Predicate<? super T>, Predicate<? super T>) - Static method in class reactor.function.Predicates: Returns a Predicate which evaluates to true if either both Predicate Predicates return true or neither of them do.

Y

YieldingWait() - Constructor for class reactor.timer.HashWheelTimer.YieldingWait
yieldingWaitStrategy() - Method in class reactor.core.processor.spec.ProcessorSpec: Set YieldingWaitStrategy as wait strategy.

$ A B C D E F G H I J K L M N O P Q R S T U V W X Y