Share

Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



# Classes and Interfaces in #Reactor - 312 results found.
NameDescriptionTypePackageFrameworkJavaDoc
AbstractLifecycleDispatcherA Dispatcher that has a lifecycle.Classreactor.core.dispatchReactorjavadoc
AbstractReferenceAn abstract Reference implementation that does reference counting.Classreactor.allocReactorjavadoc
ActionAn Action is a reactive component to subscribe to a Publisher and in particular to a Stream.Classreactor.rx.actionReactorjavadoc
AdaptiveConsumerActionClassreactor.rx.action.terminalReactorjavadoc
AfterActionClassreactor.rx.action.passiveReactorjavadoc
AgileWaitingStrategyA pair of slow and fast wait strategies to dynamically adapt to a given application loadSince:2.Classreactor.core.dispatch.waitReactorjavadoc
AllocatorAn 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.Interfacereactor.allocReactorjavadoc
AssertAssertion utility class that assists in validating arguments.Classreactor.core.supportReactorjavadoc
AsyncAppenderA Logback Appender implementation that uses a Reactor RingBufferProcessor to queue events to a single-writer thread.Classreactor.logbackReactorjavadoc
BarrierStreamA BarrierStream provides a type of Stream into which you can bind Consumers and Functions from arbitrary components.Classreactor.rx.streamReactorjavadoc
BatchActionClassreactor.rx.action.aggregationReactorjavadoc
BatchSubscriptionA Subscription wrapper which requestAuthor:Stephane MaldiniClassreactor.rx.subscriptionReactorjavadoc
BehaviorBroadcasterA Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.Classreactor.rx.broadcastReactorjavadoc
BiConsumerInterfacereactor.fnReactorjavadoc
BiFunctionInterfacereactor.fnReactorjavadoc
BiStreamsA Streams add-on to work with key/value pairs hydrated in Tuple2.Classreactor.rxReactorjavadoc
BroadcasterA Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.Classreactor.rx.broadcastReactorjavadoc
BufferA Buffer is a general-purpose IO utility class that wraps a ByteBuffer.Classreactor.io.bufferReactorjavadoc
BufferActionClassreactor.rx.action.aggregationReactorjavadoc
BufferAllocatorAn Allocator implementation that allocates Buffers.Classreactor.io.bufferReactorjavadoc
BufferCodecClassreactor.io.codecReactorjavadoc
BufferShiftActionClassreactor.rx.action.aggregationReactorjavadoc
BufferShiftWhenActionClassreactor.rx.action.aggregationReactorjavadoc
BufferWhenActionClassreactor.rx.action.aggregationReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

BusBasic unit of event handling in Reactor.Interfacereactor.busReactorjavadoc
BusPublisherEmit signals whenever an Event arrives from the Selector topic from the Bus.Classreactor.bus.publisherReactorjavadoc
ByteArrayCodecA simple Codec implementation that turns a Buffer into a byte[] andAuthor:Jon Brisbin, Stephane MaldiniClassreactor.io.codecReactorjavadoc
CachableRegistrationClassreactor.bus.registryReactorjavadoc
CacheActionClassreactor.rx.action.aggregationReactorjavadoc
CachingRegistryClassreactor.bus.registryReactorjavadoc
CallbackActionClassreactor.rx.action.passiveReactorjavadoc
CallbackEventSimple Event implementation that attaches a callback to an Event and passes it to a delegate Consumer.Classreactor.bus.supportReactorjavadoc
CancelExceptionAn exception signal from downstream subscribers consuming data when their state is denying any additional event.Classreactor.core.processorReactorjavadoc
ChronicleQueuePersistorA QueuePersistor implementation that uses a Java Chronicle IndexedChronicle to persist items in the queue.Classreactor.io.queueReactorjavadoc
ChronicleReaderStream queue tasks to execute.Classreactor.rx.stream.ioReactorjavadoc
ChronicleStreamClassreactor.rx.stream.ioReactorjavadoc
ClassSelectorClassreactor.bus.selectorReactorjavadoc
ClientSocketOptionsClassreactor.io.net.configReactorjavadoc
ClosureTupleConsumerClassreactor.groovy.supportReactorjavadoc
Codec instance of IN and passing that to the given Consumer.Classreactor.io.codecReactorjavadoc
CombineLatestActionClassreactor.rx.action.combinationReactorjavadoc
CommonSocketOptionsEncapsulates common socket options.Classreactor.io.net.configReactorjavadoc
CompletableBlockingQueueA LinkedQueue that supports a terminal state.Classreactor.core.queueReactorjavadoc
CompletableLinkedQueueA LinkedQueue that supports a terminal state.Classreactor.core.queueReactorjavadoc
CompletableQueueQueues that support a terminal stateSince:2.Interfacereactor.core.queueReactorjavadoc
CompositeActionCreate a Processor where a given head/tail couple is provided as a Stream (Input upstream) and Action (OutputSince:2.Classreactor.rx.actionReactorjavadoc
CompressionCodecClassreactor.io.codec.compressReactorjavadoc
ConcatActionClassreactor.rx.action.combinationReactorjavadoc
ConfigurationReaderA ConfigurationReader is used to read Reactor configuration.Interfacereactor.core.configReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ConsumerInterfacereactor.fnReactorjavadoc
ConsumerActionClassreactor.rx.action.terminalReactorjavadoc
ConsumerFilteringRouterAn Router that filters consumers before routing events toAuthor:Andy Wilkinson, Stephane MaldiniClassreactor.bus.routingReactorjavadoc
ControlAn interface generally associated with a Stream terminal action such as Stream.Interfacereactor.rx.actionReactorjavadoc
CountActionClassreactor.rx.action.metricsReactorjavadoc
DatagramServerClassreactor.io.net.udpReactorjavadoc
DefaultIfEmptyActionClassreactor.rx.action.transformationReactorjavadoc
DefaultSubscriberClassreactor.rx.action.supportReactorjavadoc
DeferredStreamA Publisher supplier that will call the passed supplier on each subscribe call.Classreactor.rx.streamReactorjavadoc
DelimitedCodecAn 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.Classreactor.io.codecReactorjavadoc
DematerializeActionClassreactor.rx.action.transformationReactorjavadoc
DispatcherA Dispatcher is used to dispatch(Object, Consumer, Consumer) dispatch} data to Consumers.Interfacereactor.coreReactorjavadoc
DispatcherActionClassreactor.rx.action.controlReactorjavadoc
DispatcherComponentSpecA generic environment-aware class for specifying components that need to be configured with an Environment and Dispatcher.Classreactor.bus.specReactorjavadoc
DispatcherConfigurationAn encapsulation of the configuration for a Dispatcher.Classreactor.core.configReactorjavadoc
DispatcherSupplierA Dispatcher Supplier with shutdown capacities to clean produced dispatchers.Interfacereactor.coreReactorjavadoc
DispatcherTypeAn enumeration of supported types of Dispatcher.Classreactor.core.configReactorjavadoc
DistinctActionClassreactor.rx.action.filterReactorjavadoc
DistinctUntilChangedActionClassreactor.rx.action.filterReactorjavadoc
DropSubscriptionRelationship between a Stream (Publisher) and a Subscriber.Classreactor.rx.subscriptionReactorjavadoc
DurableAsyncAppenderAn AsyncAppender subclass that first writes a log event to a durable Chronicle using Java Chronicle before allowing the event to be queued.Classreactor.logbackReactorjavadoc
DurableLogUtilityClassreactor.logbackReactorjavadoc
DynamicMergeActionClassreactor.rx.action.combinationReactorjavadoc
ElapsedActionClassreactor.rx.action.metricsReactorjavadoc
ElementAtActionClassreactor.rx.action.filterReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

EnvironmentClassreactorReactorjavadoc
ErrorActionClassreactor.rx.action.errorReactorjavadoc
ErrorReturnActionClassreactor.rx.action.errorReactorjavadoc
ErrorStreamA Stream that emits a sigle error signal.Classreactor.rx.streamReactorjavadoc
ErrorWithValueActionClassreactor.rx.action.errorReactorjavadoc
EventWrapper for an object that needs to be processed by Consumers.Classreactor.busReactorjavadoc
EventAllocatorGeneric Event Allocator.Classreactor.allocReactorjavadoc
EventBusA reactor is an event gateway that allows other components to register Event Consumers that can subsequently be notified of events.Classreactor.busReactorjavadoc
EventBusSpecA helper class for configuring a new EventBus.Classreactor.bus.specReactorjavadoc
EventConsumerSimple Consumer implementation that pulls the data from an Event and passes it to a delegate Consumer.Classreactor.bus.supportReactorjavadoc
EventFactorySupplierA Supplier implementation that instantiates Events based on Event data type.Classreactor.allocReactorjavadoc
EventRoutingComponentSpecA generic environment-aware class for specifying components that need to be configured with an Environment, Dispatcher, and Router.Classreactor.bus.specReactorjavadoc
EventTimerA hashed wheel timer implementation that uses a Registry and custom Selectors to determine when tasks should be executed.Classreactor.bus.timerReactorjavadoc
ExceptionsStatic Helpers to decorate an exception with an associated data Original design from https://github.Classreactor.core.supportReactorjavadoc
ExecutorPoweredProcessorA base processor used by executor backed processors to take care of their ExecutorServiceAuthor:Stephane MaldiniClassreactor.core.processorReactorjavadoc
ExistsActionClassreactor.rx.action.conditionalReactorjavadoc
FallbackActionClassreactor.rx.action.errorReactorjavadoc
FanInActionThe best moment of my life so far, not.Classreactor.rx.action.combinationReactorjavadoc
FanInSubscriptionClassreactor.rx.action.combinationReactorjavadoc
FanOutSubscriptionA composite subscription used to achieve pub/sub pattern.Classreactor.rx.subscriptionReactorjavadoc
FilterA Filter is used to filter a list of items.Interfacereactor.bus.filterReactorjavadoc
FilterActionClassreactor.rx.action.filterReactorjavadoc
FinallyActionClassreactor.rx.action.passiveReactorjavadoc
FirstFilterA Filter implementation that returns the first item.Classreactor.bus.filterReactorjavadoc
FlowControlActionClassreactor.rx.action.controlReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

FrameClassreactor.io.codecReactorjavadoc
FrameCodecCodec for decoding data into length-field-based Frames.Classreactor.io.codecReactorjavadoc
FunctionInterfacereactor.fnReactorjavadoc
FunctionsHelper methods to provide syntax sugar for working with functional components in Reactor.Classreactor.fnReactorjavadoc
FutureStreamA Stream that emits a result of a Future and then complete.Classreactor.rx.streamReactorjavadoc
GroupByActionManage a dynamic registry of substreams for a given key extracted from the incoming data.Classreactor.rx.action.transformationReactorjavadoc
GroupedStreamThe Stream will complete or fail whever the parent groupBy action terminates itself.Classreactor.rx.streamReactorjavadoc
GzipCodecClassreactor.io.codec.compressReactorjavadoc
HashWheelTimerHash Wheel Timer, as per the paper: Hashed and hierarchical timing wheels:Classreactor.fn.timerReactorjavadoc
HeaderResolverResponsible for extracting any applicable headers from a key.Interfacereactor.bus.selectorReactorjavadoc
HeadersHeader names common to HTTP requests and responsesAuthor:Sebastien DeleuzeInterfacereactor.io.net.http.modelReactorjavadoc
HttpChannelA Request/Response ChannelStream extension that provides for several helpers to control HTTP behavior and observe its metadata.Classreactor.io.net.httpReactorjavadoc
HttpClientThe base class for a Reactor-based Http client.Classreactor.io.net.httpReactorjavadoc
HttpExceptionAn exception for signalling that an error occurred during a communication over HTTP protocolAuthor:Anatoly KadyshevSee Also:Serialized FormClassreactor.io.net.httpReactorjavadoc
HttpHeadersInterfacereactor.io.net.http.modelReactorjavadoc
HttpSelectorA Selector to match against ServerRequestAuthor:Stephane MaldiniClassreactor.io.net.httpReactorjavadoc
HttpServerBase functionality needed by all servers that communicate with clients over HTTP.Classreactor.io.net.httpReactorjavadoc
IgnoreErrorActionClassreactor.rx.action.errorReactorjavadoc
InMemoryQueuePersistorA QueuePersistor implementations that stores items in-memory.Classreactor.io.queueReactorjavadoc
InsufficientCapacityExceptionException thrown when the it is not possible to dispatch a signal a Dispatcher.Classreactor.core.processorReactorjavadoc
IOA factory for Reactive basic IO operations such as File read/write, Byte read and Codec decoding.Classreactor.ioReactorjavadoc
IOStreamsA Streams add-on to work with IO components such as ChronicleStreams.Classreactor.rxReactorjavadoc
IterableStreamA Stream that emits Iterable values one by one and then complete.Classreactor.rx.streamReactorjavadoc
JacksonJsonCodecClassreactor.io.codec.jsonReactorjavadoc
JavaSerializationCodecCodec to transform Java objects into Buffers and visa-versa.Classreactor.io.codecReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

JsonCodecA codec for decoding JSON into Java objects and encoding Java objects into JSON.Classreactor.io.codec.jsonReactorjavadoc
JsonPathSelectorClassreactor.bus.selectorReactorjavadoc
KryoCodecClassreactor.io.codec.kryoReactorjavadoc
KryoPoolCodecClassreactor.io.codec.kryoReactorjavadoc
LastActionClassreactor.rx.action.aggregationReactorjavadoc
LengthFieldCodecA codec that uses a length-field at the start of each chunk to denote the chunk's size.Classreactor.io.codecReactorjavadoc
LiftStreamA Stream wrapper that defers a parent stream subscription to the child action subscribe() call.Classreactor.rx.streamReactorjavadoc
LoggerActionClassreactor.rx.action.passiveReactorjavadoc
MapActionClassreactor.rx.action.transformationReactorjavadoc
MapStreamA SubscribableMap is an event-driven Map that signals logged operations to its subscribers.Classreactor.rx.streamReactorjavadoc
MatchAllSelectorClassreactor.bus.selectorReactorjavadoc
MaterializeActionClassreactor.rx.action.transformationReactorjavadoc
MergeActionClassreactor.rx.action.combinationReactorjavadoc
MethodA Model representation of supported HTTP MethodsAuthor:Sebastien Deleuze, Stephane MaldiniClassreactor.io.net.http.modelReactorjavadoc
MpscDispatcher queue tasks to execute.Classreactor.core.dispatchReactorjavadoc
MpscLinkedQueueA MultiProduceSingleConsumer impl.Classreactor.core.queue.internalReactorjavadoc
MpscLinkedQueueNodeClassreactor.core.queue.internalReactorjavadoc
MultiThreadDispatcherBase implementation for multi-threaded dispatchersSince:1.Classreactor.core.dispatchReactorjavadoc
MutableSignalClassreactor.core.processorReactorjavadoc
NamedDaemonThreadFactoryA thread factory that creates named daemon threads.Classreactor.core.supportReactorjavadoc
NetSelectorsHelper methods for creating Selectors.Classreactor.io.netReactorjavadoc
NetStreamsA Streams add-on to work with network facilities from reactor-net, e.Classreactor.io.netReactorjavadoc
NettyChannelHandlerBridgeNetty ChannelInboundHandler implementation that passes data to a Reactor ChannelStream.Classreactor.io.net.impl.nettyReactorjavadoc
NettyChannelStreamReactorChannel implementation that delegates to Netty.Classreactor.io.net.impl.nettyReactorjavadoc
NettyClientSocketOptionsClassreactor.io.net.impl.nettyReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

NettyDatagramServerDatagramServer implementation built on Netty.Classreactor.io.net.impl.netty.udpReactorjavadoc
NettyHttpChannelClassreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpClientA Netty-based TcpClient.Classreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpClientHandlerClassreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpHeadersClassreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpResponseHeadersClassreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpServerA Netty-based TcpServer implementationAuthor:Jon Brisbin, Stephane MaldiniClassreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpServerHandlerConversion between Netty types and Reactor types (NettyHttpChannel and Buffer).Classreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpWSClientHandlerClassreactor.io.net.impl.netty.httpReactorjavadoc
NettyHttpWSServerHandlerConversion between Netty types and Reactor types (NettyHttpChannel and Buffer).Classreactor.io.net.impl.netty.httpReactorjavadoc
NettyNativeDetectorClassreactor.io.net.impl.nettyReactorjavadoc
NettyServerSocketOptionsClassreactor.io.net.impl.nettyReactorjavadoc
NettyTcpClientA Netty-based TcpClient.Classreactor.io.net.impl.netty.tcpReactorjavadoc
NettyTcpServerA Netty-based TcpServer implementationAuthor:Jon Brisbin, Stephane MaldiniClassreactor.io.net.impl.netty.tcpReactorjavadoc
NonBlockingA dispatcher aware componentAuthor:Stephane MaldiniInterfacereactor.core.supportReactorjavadoc
NotifyConsumerA Consumer that notifies an observable of each value that it has accepted.Classreactor.bus.supportReactorjavadoc
ObjectSelectorSelector implementation that uses the Object.Classreactor.bus.selectorReactorjavadoc
ParkWaitStrategyClassreactor.core.dispatch.waitReactorjavadoc
PassThroughCodecA simple Codec that uses the source object as both input and output.Classreactor.io.codecReactorjavadoc
PassThroughFilterA Filter implementation that performs no filtering, returning the items as-is.Classreactor.bus.filterReactorjavadoc
PausableInterfacereactor.fnReactorjavadoc
PeriodicTimerStreamA Stream that emits 0 after an initial delay and ever incrementing long counter if the period argument is The TimerStream will manage dedicated timers for new subscriber assigned viaClassreactor.rx.streamReactorjavadoc
PersistentQueueA PersistentQueue is a Queue implementation that delegates the actual storage of the elements in the queue to a QueuePersistor.Classreactor.io.queueReactorjavadoc
PersistentQueueSpecHelper spec to create a PersistentQueue instance.Classreactor.io.queue.specReactorjavadoc
PlatformDependentBorrowed from Netty project which itself borrows from JCTools and various other projects.Classreactor.core.internalReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

PredicateDetermines if the input object matches some criteria.Interfacereactor.fnReactorjavadoc
PredicatesClassreactor.fnReactorjavadoc
PredicateSelectorClassreactor.bus.selectorReactorjavadoc
PromiseA Promise is a stateful event container that accepts a single value or error.Classreactor.rxReactorjavadoc
PromisesHelper methods for creating Promise instances.Classreactor.rxReactorjavadoc
PropertiesConfigurationReaderA ConfigurationReader that reads the configuration from properties files and System properties.Classreactor.core.configReactorjavadoc
ProtobufCodecClassreactor.io.codec.protobufReactorjavadoc
ProtocolA Model representation of supported HTTP ProtocolsAuthor:Sebastien Deleuze, Stephane MaldiniClassreactor.io.net.http.modelReactorjavadoc
PublisherFactoryA Reactive Streams Publisher factory which callbacks on start, request and shutdown The Publisher will directly forward all the signals passed to the subscribers and complete when onComplete is called.Classreactor.core.reactivestreamsReactorjavadoc
PublisherStreamA Publisher wrapper that takes care of lazy subscribing.Classreactor.rx.streamReactorjavadoc
PushSubscriptionRelationship between a Stream (Publisher) and a Subscriber.Classreactor.rx.subscriptionReactorjavadoc
QueuePersistor Persistence could be achieved through in-memory solutions like a Map or could be more complex and use a backing datastore.Interfacereactor.io.queueReactorjavadoc
RandomFilterA Filter implementation that returns a single, randomly selected item.Classreactor.bus.filterReactorjavadoc
RangeStreamA Stream that emits N Long from the inclusive start value defined to the inclusive end and then Since the stream retains the boundaries in a final field, any SubscriberClassreactor.rx.streamReactorjavadoc
ReactiveSubscriptionRelationship between a Stream (Publisher) and a Subscriber.Classreactor.rx.subscriptionReactorjavadoc
ReactorChannelHandlerA ReactorChannel callback that is attached on ReactorPeer or ReactorClient initialization and receives all connected ReactorChannel.Interfacereactor.io.netReactorjavadoc
ReactorClientA network-aware client that will publish its connection once available to the ReactorChannelHandler passed.Classreactor.io.netReactorjavadoc
ReactorConfigurationAn encapsulation of configuration for ReactorAuthor:Andy Wilkinson, Jon BrisbinClassreactor.core.configReactorjavadoc
ReactorFatalExceptionan exception that should stop producing more dataSince:2.Classreactor.core.supportReactorjavadoc
ReactorPeerAbstract base class that implements common functionality shared by clients and servers.Classreactor.io.netReactorjavadoc
ReactorProcessorClassreactor.core.processorReactorjavadoc
ReadableHeadersInterfacereactor.io.net.http.modelReactorjavadoc
Reconnect to the TcpClient whether or not to attempt to reconnect a broken connection.Interfacereactor.io.netReactorjavadoc
RecyclableA simple interface that marks an object as being recyclable.Interfacereactor.core.supportReactorjavadoc
RecyclableNumberClassreactor.allocReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

RecyclableStringClassreactor.allocReactorjavadoc
ReduceByKeyActionClassreactor.rx.action.pairReactorjavadoc
ReferenceA Reference provides access to and metadata about a poolable object.Interfacereactor.allocReactorjavadoc
ReferenceCountingAllocatorAn implementation of Allocator that uses reference counting to determine when an object be recycled and placed back into the pool to be reused.Classreactor.allocReactorjavadoc
RegexSelectorA Selector implementation based on the given regular expression.Classreactor.bus.selectorReactorjavadoc
RegistrationA Registration represents an object that has been registered with a Registry.Interfacereactor.bus.registryReactorjavadoc
RegistriesClassreactor.bus.registryReactorjavadoc
Registry use simple keys, they use Selectors to map their objects.Interfacereactor.bus.registryReactorjavadoc
RepeatActionClassreactor.rx.action.controlReactorjavadoc
RepeatWhenActionClassreactor.rx.action.controlReactorjavadoc
ResourceA Resource is a component with an active state, generally consuming hardware capacities (memory, cpu, io).Interfacereactor.fnReactorjavadoc
ResponseHeadersInterfacereactor.io.net.http.modelReactorjavadoc
RetryActionClassreactor.rx.action.errorReactorjavadoc
RetryWhenActionClassreactor.rx.action.errorReactorjavadoc
RingBufferDispatcherClassreactor.core.dispatchReactorjavadoc
RingBufferProcessorAn implementation of a RingBuffer backed message-passing Processor.Classreactor.core.processorReactorjavadoc
RingBufferSubscriberUtilsUtility methods to perform common tasks associated with Subscriber handling when the signals are stored in a com.Classreactor.core.processor.utilReactorjavadoc
RingBufferWorkProcessorAn implementation of a RingBuffer backed message-passing WorkProcessor.Classreactor.core.processorReactorjavadoc
RoundRobinFilterA Filter implementation that returns a single item.Classreactor.bus.filterReactorjavadoc
RouterAn Router is used to route an Object to Consumers.Interfacereactor.bus.routingReactorjavadoc
SampleActionClassreactor.rx.action.aggregationReactorjavadoc
ScanActionClassreactor.rx.action.transformationReactorjavadoc
ScanByKeyActionClassreactor.rx.action.pairReactorjavadoc
SelectorA Selector is a wrapper around an arbitrary object.Interfacereactor.bus.selectorReactorjavadoc
SelectorsHelper methods for creating Selectors.Classreactor.bus.selectorReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

SerializationCodecAbstract base class for Codec Codecs that perform serialization of objects.Classreactor.io.codecReactorjavadoc
SerializedBroadcasterA Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline.Classreactor.rx.broadcastReactorjavadoc
SerializedSubscriberEnforces single-threaded, serialized, ordered execution of onNext(T), onComplete(), onError(java.Classreactor.core.reactivestreamsReactorjavadoc
ServerSocketOptionsEncapsulates configuration options for server sockets.Classreactor.io.net.configReactorjavadoc
SetMembershipSelector objects on set membership.Classreactor.bus.selectorReactorjavadoc
SignalA domain representation of a Reactive Stream signal.Classreactor.rx.actionReactorjavadoc
SimpleCachingRegistryA naive caching Registry implementation for use in situations that the default CachingRegistry can't be used due to its reliance on the gs-collections library.Classreactor.bus.registryReactorjavadoc
SingleThreadDispatcherBase Implementation for single-threaded Dispatchers.Classreactor.core.dispatchReactorjavadoc
SingleTimerStreamA Stream that emits 0 after an initial delay and then complete The SingleTimerStream will manage dedicated timers for new subscriber assigned viaClassreactor.rx.streamReactorjavadoc
SingleUseExecutorClassreactor.core.processor.utilReactorjavadoc
SingleValueStreamA Stream that emits only one value and then complete.Classreactor.rx.streamReactorjavadoc
SkipActionClassreactor.rx.action.filterReactorjavadoc
SkipUntilTimeoutClassreactor.rx.action.filterReactorjavadoc
SnappyCodecClassreactor.io.codec.compressReactorjavadoc
SocketUtilsNOTE: This code is a copy of that available in the Spring Framework.Classreactor.io.net.tcp.supportReactorjavadoc
SortActionClassreactor.rx.action.aggregationReactorjavadoc
SpecSpecifications used to build client and servers.Interfacereactor.io.netReactorjavadoc
SpecificationExceptionsClassreactor.core.supportReactorjavadoc
SplitActionClassreactor.rx.action.transformationReactorjavadoc
SSLEngineSupplierClassreactor.io.net.tcp.sslReactorjavadoc
SslOptionsHelper class encapsulating common SSL configuration options.Classreactor.io.net.configReactorjavadoc
StandardCodecsA selection of standard codecs.Classreactor.io.codecReactorjavadoc
StatusClassreactor.io.net.http.modelReactorjavadoc
StreamRouterClassreactor.groovy.configReactorjavadoc
StreamsA public factory to build Stream, Streams provide for common transformations from a few structures such as Iterable or Future to a Stream, in addition to provide for combinatory operations (merge, switchOnNext.Classreactor.rxReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

StreamStateCallbackActionClassreactor.rx.action.passiveReactorjavadoc
StreamUtilsA simple collection of utils to assist in various tasks such as DebuggingSince:1.Classreactor.rxReactorjavadoc
StringCodecClassreactor.io.codecReactorjavadoc
SubscriberBarrierA Subscriber with an asymetric typed wrapped subscriber.Classreactor.core.reactivestreamsReactorjavadoc
SubscriberFactoryA Reactive Streams Subscriber factory which callbacks on start, onNext, onError and shutdown The Publisher will directly forward all the signals passed to the subscribers and complete when onComplete is called.Classreactor.core.reactivestreamsReactorjavadoc
SubscriberWithContextA Subscriber with a typed stateful context.Classreactor.core.reactivestreamsReactorjavadoc
SubscriptionWithContextA Subscription with a typed stateful context.Classreactor.core.reactivestreamsReactorjavadoc
Supplier get() or can be created in some other way.Interfacereactor.fnReactorjavadoc
SuppliersHelper class for working tying Suppliers to Iterables and other types ofCreate a Supplier that aggregates the given list of suppliers by calling each one, inClassreactor.fnReactorjavadoc
SupplierStreamA Stream that returns the result from Supplier.Classreactor.rx.streamReactorjavadoc
SwitchActionClassreactor.rx.action.combinationReactorjavadoc
SynchronousDispatcherA Dispatcher implementation that dispatches events using the calling thread.Classreactor.core.dispatchReactorjavadoc
SyslogCodecA coded for consuming syslog messages.Classreactor.io.net.codec.syslogReactorjavadoc
SyslogMessageClassreactor.io.net.codec.syslogReactorjavadoc
TailRecurseDispatcherA Dispatcher implementation that trampolines events using the calling thread and.Classreactor.core.dispatchReactorjavadoc
TakeActionClassreactor.rx.action.filterReactorjavadoc
TakeUntilTimeoutClassreactor.rx.action.filterReactorjavadoc
TakeWhileActionClassreactor.rx.action.filterReactorjavadoc
TapA Tap provides a limited window into an event stream.Classreactor.fn.supportReactorjavadoc
TapAndControlsClassreactor.rx.action.supportReactorjavadoc
TcpClientThe base class for a Reactor-based TCP client.Classreactor.io.net.tcpReactorjavadoc
TcpServerBase functionality needed by all servers that communicate with clients over TCP.Classreactor.io.net.tcpReactorjavadoc
ThreadPoolExecutorDispatcherA Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events.Classreactor.core.dispatchReactorjavadoc
ThrottleRequestActionClassreactor.rx.action.controlReactorjavadoc
ThrottleRequestWhenActionClassreactor.rx.action.controlReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

TimeoutActionClassreactor.rx.action.errorReactorjavadoc
TimerInterfacereactor.fn.timerReactorjavadoc
TimestampActionClassreactor.rx.action.metricsReactorjavadoc
TimeUtilsClassreactor.fn.timerReactorjavadoc
TraceableDelegatingDispatcherAn implementation of Dispatcher that traces activity through it.Classreactor.core.dispatchReactorjavadoc
TraceableDelegatingFilterClassreactor.bus.filterReactorjavadoc
TraceableDelegatingRouterClassreactor.bus.routingReactorjavadoc
TransferClassreactor.io.net.http.modelReactorjavadoc
TupleA Tuple is an immutable Collection of objects, each of which can be of an arbitrary type.Classreactor.fn.tupleReactorjavadoc
Tuple1A tuple that holds a single valueAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple2A tuple that holds two valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple3A tuple that holds three valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple4A tuple that holds four valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple5A tuple that holds five valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple6A tuple that holds six valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple7A tuple that holds seven valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
Tuple8A tuple that holds eight valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
TupleNA tuple that holds 9 or more valuesAuthor:Jon Brisbin, Stephane MaldiniSee Also:Serialized FormClassreactor.fn.tupleReactorjavadoc
UriPathSelectorA Selector implementation based on a UriPathTemplate.Classreactor.bus.selectorReactorjavadoc
UriPathTemplateRepresents a URI template.Classreactor.bus.selectorReactorjavadoc
UriSelectorA Selector implementation that matches on various components of a full URI.Classreactor.bus.selectorReactorjavadoc
UUIDUtilsHelper for creating random and Type 1 (time-based) UUIDs.Classreactor.core.supportReactorjavadoc
WaitingMoodA Component with some waiting capacities such as Dispatcher that uses a CPU-friendly strategy (e.Interfacereactor.core.dispatch.waitReactorjavadoc
WindowActionWindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream.Classreactor.rx.action.aggregationReactorjavadoc
WindowShiftActionWindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream.Classreactor.rx.action.aggregationReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

WindowShiftWhenActionWindowAction is forwarding events on a steam until is reached, after that streams collected events further, complete it and create a fresh new stream.Classreactor.rx.action.aggregationReactorjavadoc
WindowWhenActionWindowAction is forwarding events on a steam until returned stream emits a signal, after that streams collected events further, complete it and create a fresh new stream.Classreactor.rx.action.aggregationReactorjavadoc
WorkQueueDispatcherClassreactor.core.dispatchReactorjavadoc
WrappedSubscriptionClassreactor.rx.subscription.supportReactorjavadoc
WritableHeadersInterfacereactor.io.net.http.modelReactorjavadoc
ZeroMQClassreactor.io.net.impl.zmq.tcpReactorjavadoc
ZeroMQChannelStreamClassreactor.io.net.impl.zmqReactorjavadoc
ZeroMQClientSocketOptionsClientSocketOptions that include ZeroMQ-specific configuration options.Classreactor.io.net.impl.zmqReactorjavadoc
ZeroMQServerSocketOptionsServerSocketOptions that include ZeroMQ-specific configuration options.Classreactor.io.net.impl.zmqReactorjavadoc
ZeroMQTcpClientClassreactor.io.net.impl.zmq.tcpReactorjavadoc
ZeroMQTcpServerClassreactor.io.net.impl.zmq.tcpReactorjavadoc
ZeroMQWorkerClassreactor.io.net.impl.zmqReactorjavadoc
ZipActionClassreactor.rx.action.combinationReactorjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner



comments powered by Disqus