Skip navigation links
Reactor JavaDocs

Reactor JavaDoc 2.0.8.RELEASE

This document is the API specification for the Reactor FastData library.

See: Description

Packages 
Package Description
reactor  
reactor.alloc
Pooling provides lower GC requirements by re-using components.
reactor.bus
Hold the required abstraction to enable Event Driven Programming with Reactor.
reactor.bus.filter
Filters eliminate components from a list based on a predicate.
reactor.bus.publisher  
reactor.bus.registry
Registries provide a common way to retrieve items registered using a Selector.
reactor.bus.routing
Event routing means sending a given Event to the correct Consumers.
reactor.bus.selector
Selectors provide a way to register components to react to given key data.
reactor.bus.spec
Specs help create Reactors by providing a fluent API to specify common options.
reactor.bus.support  
reactor.bus.timer  
reactor.core
Core components of the Reactor framework.
reactor.core.config
Components to facilitate flexible configuration of the Reactor Environment.
reactor.core.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.core.dispatch.wait  
reactor.core.internal
Core components of the Reactor framework.
reactor.core.processor
This package offers a suite of asynchronous Processor with backpressure support.
reactor.core.processor.util  
reactor.core.queue
Queue implementations that provide completable states or lock-free queue
reactor.core.queue.internal  
reactor.core.reactivestreams  
reactor.core.support  
reactor.fn
This package contains the foundational abstractions on which Reactor's functional and reactive components are built.
reactor.fn.support  
reactor.fn.timer  
reactor.fn.tuple
Tuples provide a type-safe way to specify multiple parameters.
reactor.groovy.config  
reactor.groovy.ext  
reactor.groovy.support  
reactor.io
Buffer-handling and other IO-related components.
reactor.io.buffer  
reactor.io.codec
Components to handle encoding and decoding of objects into Buffers.
reactor.io.codec.compress  
reactor.io.codec.json
Encoding and decoding using the JSON format.
reactor.io.codec.kryo  
reactor.io.codec.protobuf  
reactor.io.net
Reactive network components are located in this package scope implementing the following exposed contract: A ReactorPeer NetServer/NetClient is a Publisher of ReactorChannel that are themselves Publisher of input data.
reactor.io.net.codec.syslog
Decoding using the syslog format.
reactor.io.net.config
Configuration of the various TCP parameters for clients and servers.
reactor.io.net.http
Components for writing HTTP-based clients and servers using Reactor abstractions.
reactor.io.net.http.model  
reactor.io.net.impl.netty
Implementations of the various TCP abstractions based on Netty.
reactor.io.net.impl.netty.http  
reactor.io.net.impl.netty.tcp  
reactor.io.net.impl.netty.udp  
reactor.io.net.impl.zmq  
reactor.io.net.impl.zmq.tcp  
reactor.io.net.tcp
Components for writing TCP-based clients and servers using Reactor abstractions.
reactor.io.net.tcp.ssl
Support classes for Reactor's TCP SSL support.
reactor.io.net.tcp.support  
reactor.io.net.udp  
reactor.io.queue
Queue implementations that provide a persistence strategy for making sure items in the Queue aren't lost.
reactor.io.queue.spec
Specs provide a simple fluent DSL for creating PersistentQueues by specifying common options.
reactor.logback  
reactor.rx
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
reactor.rx.action
Actions are Reactive Streams components derived from Reactive Extensions and beyond.
reactor.rx.action.aggregation  
reactor.rx.action.combination  
reactor.rx.action.conditional  
reactor.rx.action.control  
reactor.rx.action.error  
reactor.rx.action.filter  
reactor.rx.action.metrics  
reactor.rx.action.pair  
reactor.rx.action.passive  
reactor.rx.action.support  
reactor.rx.action.terminal  
reactor.rx.action.transformation  
reactor.rx.broadcast
Broadcasters are akin to Reactive Extensions Subject.
reactor.rx.stream  
reactor.rx.stream.io
Stream implementations that provide for IO access, for instance read/read-write persisting streams
reactor.rx.subscription  
reactor.rx.subscription.support  
This document is the API specification for the Reactor FastData library.

Reactor is a succinct and powerful foundational library for building reactive, FastData applications on the JVM. More detailed documentation is available on the GitHub Wiki pages for Project Reactor.

Skip navigation links
Reactor JavaDocs

Copyright © 2017. All rights reserved.