Package | Description |
---|---|
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.spec |
Specs help create
Reactors by providing a fluent API to specify
common options. |
reactor.core |
Core components of the Reactor framework.
|
reactor.fn |
This package contains the foundational abstractions on which Reactor's functional and reactive components are
built.
|
reactor.fn.support | |
reactor.groovy.config | |
reactor.groovy.ext | |
reactor.groovy.support | |
reactor.io.buffer | |
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.config |
Configuration of the various TCP parameters for clients and servers.
|
reactor.io.net.impl.netty.http | |
reactor.io.net.impl.netty.tcp | |
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.queue.spec |
Specs provide a simple fluent DSL for creating
PersistentQueues by
specifying common options. |
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.control | |
reactor.rx.action.support | |
reactor.rx.stream |
Modifier and Type | Interface and Description |
---|---|
interface |
Reference<T extends Recyclable>
A
Reference provides access to and metadata about a poolable object. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractReference<T extends Recyclable>
An abstract
Reference implementation that does reference counting. |
class |
EventFactorySupplier<T>
A
Supplier implementation that instantiates Events
based on Event data type. |
Constructor and Description |
---|
ReferenceCountingAllocator(int initialSize,
Supplier<T> factory) |
ReferenceCountingAllocator(Supplier<T> factory) |
Modifier and Type | Method and Description |
---|---|
EventBus |
EventBus.notify(Object key,
Supplier<? extends Event<?>> supplier)
Notify this component that the given
Supplier can provide an event that's ready to be
processed. |
EventBus |
EventBus.send(Object key,
Supplier<? extends Event<?>> supplier)
|
EventBus |
EventBus.send(Object key,
Supplier<? extends Event<?>> supplier,
Bus replyTo)
|
<T extends Event<?>> |
EventBus.sendAndReceive(Object key,
Supplier<? extends Event<?>> supplier,
Consumer<T> reply)
|
Modifier and Type | Class and Description |
---|---|
class |
DispatcherComponentSpec<SPEC extends DispatcherComponentSpec<SPEC,TARGET>,TARGET>
A generic environment-aware class for specifying components that need to be configured
with an
Environment and Dispatcher . |
class |
EventBusSpec
A helper class for configuring a new
EventBus . |
class |
EventRoutingComponentSpec<SPEC extends EventRoutingComponentSpec<SPEC,TARGET>,TARGET>
A generic environment-aware class for specifying components that need to be configured with an
Environment ,
Dispatcher , and Router . |
Modifier and Type | Interface and Description |
---|---|
interface |
DispatcherSupplier
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T> Supplier<T> |
Suppliers.collect(List<Supplier<T>> suppliers)
Deprecated.
Create a
Supplier that aggregates the given list of suppliers by calling each one, in
turn, until the supplier returns null . |
static <T> Supplier<T> |
Suppliers.drain(Iterable<T> c)
Deprecated.
Create a
Supplier which drains the contents of the given Iterable by
internally creating an Iterator and delegating each call of get() to Iterator.next() . |
static <T> Supplier<T> |
Suppliers.drainAll(Iterable<Iterable<T>> iters)
Deprecated.
|
static <T> Supplier<T> |
Suppliers.filter(Iterable<T> src,
Predicate<T> predicate)
Deprecated.
|
static <T> Supplier<T> |
Suppliers.roundRobin(T... objs)
Deprecated.
|
static <T> Supplier<T> |
Functions.supplier(Callable<T> callable)
Deprecated.
|
static <T> Supplier<T> |
Functions.supplier(Class<T> type)
Deprecated.
Creates a
Supplier that will return a new instance of type each time
it's called. |
static <T> Supplier<T> |
Functions.supplier(Future<T> future)
Deprecated.
|
static <T> Supplier<T> |
Functions.supplier(T value)
Deprecated.
Creates a
Supplier that will always return the given value . |
static <T> Supplier<T> |
Suppliers.supply(T obj)
Deprecated.
Wrap the given object that will supply the given object every time
get() is
called. |
static <T> Supplier<T> |
Suppliers.supplyOnce(T obj)
Deprecated.
Supply the given object only once, the first time
get() is invoked. |
static <T> Supplier<T> |
Suppliers.supplyWhile(T obj,
Predicate<T> predicate)
Deprecated.
Supply the given object to callers only as long as the given
Predicate returns true. |
Modifier and Type | Method and Description |
---|---|
static <T> Supplier<T> |
Suppliers.collect(List<Supplier<T>> suppliers)
Deprecated.
Create a
Supplier that aggregates the given list of suppliers by calling each one, in
turn, until the supplier returns null . |
Modifier and Type | Class and Description |
---|---|
class |
Tap<T>
A
Tap provides a limited window into an event stream. |
Modifier and Type | Class and Description |
---|---|
class |
DispatcherConfigurationBuilder |
class |
EnvironmentBuilder |
class |
ReactorBuilder |
class |
ReactorBuilder.NestedReactorBuilder |
Modifier and Type | Method and Description |
---|---|
static <T> void |
BusExtensions.call(Supplier<T> selfType) |
static <T> Bus |
BusExtensions.notify(Bus selfType,
Object key,
Supplier<Event<T>> obj) |
Modifier and Type | Class and Description |
---|---|
class |
ClosureSupplier<V> |
Modifier and Type | Class and Description |
---|---|
class |
Buffer.View
A View represents a segment of a buffer.
|
Modifier and Type | Class and Description |
---|---|
static class |
Spec.DatagramServerSpec<IN,OUT> |
static class |
Spec.HttpClientSpec<IN,OUT>
A helper class for specifying a
HttpClient |
static class |
Spec.HttpServerSpec<IN,OUT>
A HttpServer Spec is used to specify an HttpServer
|
static class |
Spec.IncrementalBackoffReconnect
A helper class for configure a new
Reconnect . |
static class |
Spec.PeerSpec<IN,OUT,CONN extends ChannelStream<IN,OUT>,S extends Spec.PeerSpec<IN,OUT,CONN,S,N>,N extends ReactorPeer<IN,OUT,CONN>> |
static class |
Spec.TcpClientSpec<IN,OUT>
A helper class for specifying a
TcpClient |
static class |
Spec.TcpServerSpec<IN,OUT>
A TcpServerSpec is used to specify a TcpServer
|
Modifier and Type | Method and Description |
---|---|
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.connect(Supplier<InetSocketAddress> connectAddress)
The eventual address to which this client should connect.
|
Spec.HttpClientSpec<IN,OUT> |
Spec.HttpClientSpec.connect(Supplier<InetSocketAddress> connectAddress)
The address to which this client should connect.
|
Modifier and Type | Method and Description |
---|---|
Supplier<TrustManager[]> |
SslOptions.trustManagers() |
Modifier and Type | Method and Description |
---|---|
SslOptions |
SslOptions.trustManagers(Supplier<TrustManager[]> trustManagers) |
Constructor and Description |
---|
NettyHttpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec)
Creates a new NettyTcpClient that will use the given
env for configuration and the given reactor to
send events. |
Constructor and Description |
---|
NettyTcpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> hostSupplier,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec)
Creates a new NettyTcpClient that will use the given
env for configuration and the given reactor to
send events. |
Constructor and Description |
---|
ZeroMQTcpClient(Environment env,
Dispatcher eventsDispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Field and Description |
---|---|
protected Supplier<InetSocketAddress> |
TcpClient.connectAddress |
Constructor and Description |
---|
TcpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Class and Description |
---|---|
class |
SSLEngineSupplier |
Modifier and Type | Class and Description |
---|---|
class |
PersistentQueueSpec<T>
Helper spec to create a
PersistentQueue instance. |
Modifier and Type | Class and Description |
---|---|
class |
Promise<O>
A
Promise is a stateful event container that accepts a single value or error. |
Modifier and Type | Method and Description |
---|---|
Stream<List<O>> |
Stream.buffer(org.reactivestreams.Publisher<?> bucketOpening,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier)
Collect incoming values into a
List that will be moved into the returned Stream every time the
passed boundary publisher emits an item. |
Stream<List<O>> |
Stream.buffer(Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier)
Collect incoming values into a
List that will be moved into the returned Stream every time the
passed boundary publisher emits an item. |
static <T> Stream<T> |
Streams.defer(Supplier<? extends org.reactivestreams.Publisher<T>> supplier)
Supply a
Publisher everytime subscribe is called on the returned stream. |
static <T> Stream<T> |
Streams.generate(Supplier<? extends T> value)
Build a Stream whose data is generated by the passed supplier on subscription request.
|
<V> Stream<V> |
Stream.lift(Supplier<? extends Action<O,V>> action)
Defer the subscription of an
Action to the actual pipeline. |
Stream<O> |
Stream.onOverflowBuffer(Supplier<? extends CompletableQueue<O>> queueSupplier)
Attach a No-Op Action that only serves the purpose of buffering incoming values if not enough demand is signaled
downstream.
|
static <T> Promise<T> |
Promises.syncTask(Supplier<T> supplier)
|
static <T> Promise<T> |
Promises.task(Environment env,
Dispatcher dispatcher,
Supplier<T> supplier)
|
static <T> Promise<T> |
Promises.task(Environment env,
Supplier<T> supplier)
|
Stream<Stream<O>> |
Stream.window(org.reactivestreams.Publisher<?> bucketOpening,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier)
Re-route incoming values into bucket streams that will be pushed into the returned
Stream every and
complete every time boundarySupplier stream emits an item. |
Stream<Stream<O>> |
Stream.window(Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier)
Re-route incoming values into bucket streams that will be pushed into the returned
Stream every and
complete every time boundarySupplier stream emits an item. |
Modifier and Type | Class and Description |
---|---|
class |
Signal<T>
A domain representation of a Reactive
Stream signal. |
Modifier and Type | Method and Description |
---|---|
Stream<O> |
Action.onOverflowBuffer(Supplier<? extends CompletableQueue<O>> queueSupplier) |
Constructor and Description |
---|
BufferShiftWhenAction(org.reactivestreams.Publisher<?> bucketOpenings,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier) |
BufferWhenAction(Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier) |
WindowShiftWhenAction(Environment environment,
Dispatcher dispatcher,
org.reactivestreams.Publisher<?> bucketOpenings,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier) |
WindowWhenAction(Environment environment,
Dispatcher dispatcher,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier) |
Constructor and Description |
---|
FlowControlAction(Supplier<? extends CompletableQueue<O>> queueSupplier) |
Modifier and Type | Class and Description |
---|---|
class |
TapAndControls<O> |
Constructor and Description |
---|
DeferredStream(Supplier<? extends org.reactivestreams.Publisher<T>> sourceFactory) |
LiftStream(Stream<O> thiz,
Supplier<? extends Action<O,V>> action) |
SupplierStream(Dispatcher dispatcher,
Supplier<? extends T> supplier) |
Copyright © 2016. All rights reserved.