Package | Description |
---|---|
reactor | |
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.groovy.config | |
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.http |
Components for writing HTTP-based clients and servers using Reactor abstractions.
|
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.udp | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.aggregation | |
reactor.rx.action.transformation | |
reactor.rx.broadcast |
Broadcasters are akin to Reactive Extensions Subject.
|
reactor.rx.stream |
Modifier and Type | Method and Description |
---|---|
Environment |
Environment.addCachedDispatchers(String name,
DispatcherSupplier dispatcherFactory)
Adds the
dispatcherFactory to the environment, storing it using the given name . |
static Environment |
Environment.assign(Environment environment)
Assign an environment to the context in order to make it available statically in the application from the current
classloader.
|
Environment |
Environment.assignErrorJournal()
Assign a default error
Consumer to listen for any call to this#routeError(Throwable) . |
Environment |
Environment.assignErrorJournal(Consumer<? super Throwable> errorJournal)
Assign the error
Consumer to listen for any call to this#routeError(Throwable) . |
static Environment |
Environment.get()
Read the context environment.
|
static Environment |
Environment.initialize()
Create and assign a context environment bound to the current classloader.
|
static Environment |
Environment.initialize(Consumer<Throwable> errorConsumer)
Create and assign a context environment bound to the current classloader.
|
static Environment |
Environment.initializeIfEmpty()
Create and assign a context environment bound to the current classloader only if it not already set.
|
Environment |
Environment.removeCachedDispatchers(String name)
Remove the
dispatcherFactory to the environment keyed as the given name . |
Environment |
Environment.removeDispatcher(String name)
Removes the Dispatcher, stored using the given
name from the environment. |
Environment |
Environment.setDispatcher(String name,
Dispatcher dispatcher)
Adds the
dispatcher to the environment, storing it using the given name . |
Modifier and Type | Method and Description |
---|---|
static Environment |
Environment.assign(Environment environment)
Assign an environment to the context in order to make it available statically in the application from the current
classloader.
|
Modifier and Type | Method and Description |
---|---|
static EventBus |
EventBus.create(Environment env)
Create a new
EventBus using the given Environment . |
static EventBus |
EventBus.create(Environment env,
Dispatcher dispatcher)
|
static EventBus |
EventBus.create(Environment env,
String dispatcher)
Create a new
EventBus using the given Environment and dispatcher name. |
Modifier and Type | Method and Description |
---|---|
protected abstract TARGET |
DispatcherComponentSpec.configure(Dispatcher dispatcher,
Environment environment) |
protected TARGET |
EventRoutingComponentSpec.configure(Dispatcher dispatcher,
Environment environment) |
protected abstract TARGET |
EventRoutingComponentSpec.configure(EventBus reactor,
Environment environment) |
protected EventBus |
EventBusSpec.configure(EventBus reactor,
Environment environment) |
SPEC |
DispatcherComponentSpec.env(Environment env)
Configures the spec, and potentially the component being configured, to use the given
environment
|
Modifier and Type | Method and Description |
---|---|
Environment |
GroovyEnvironment.environment() |
Environment |
GroovyEnvironment.environment(groovy.lang.Closure c) |
Environment |
GroovyEnvironment.environment(Environment environment) |
Environment |
GroovyEnvironment.environment(Map properties,
groovy.lang.Closure c) |
Environment |
EnvironmentBuilder.get() |
Environment |
ReactorBuilder.getEnv() |
Environment |
GroovyEnvironment.getReactorEnvironment() |
Modifier and Type | Method and Description |
---|---|
Environment |
GroovyEnvironment.environment(Environment environment) |
void |
ReactorBuilder.setEnv(Environment value) |
void |
GroovyEnvironment.setReactorEnvironment(Environment value) |
Modifier and Type | Method and Description |
---|---|
Environment |
ReactorPeer.getDefaultEnvironment()
Get the default environment for all Channel
|
Environment |
ChannelStream.getEnvironment() |
Modifier and Type | Method and Description |
---|---|
protected TcpClient<IN,OUT> |
Spec.TcpClientSpec.configure(Dispatcher dispatcher,
Environment environment) |
protected TcpServer<IN,OUT> |
Spec.TcpServerSpec.configure(Dispatcher dispatcher,
Environment env) |
protected DatagramServer<IN,OUT> |
Spec.DatagramServerSpec.configure(Dispatcher dispatcher,
Environment environment) |
protected HttpServer<IN,OUT> |
Spec.HttpServerSpec.configure(Dispatcher dispatcher,
Environment env) |
protected HttpClient<IN,OUT> |
Spec.HttpClientSpec.configure(Dispatcher dispatcher,
Environment environment) |
Constructor and Description |
---|
ChannelStream(Environment env,
Codec<Buffer,IN,OUT> codec,
long prefetch,
Dispatcher eventsDispatcher) |
ReactorClient(Environment defaultEnv,
Dispatcher defaultDispatcher,
Codec<Buffer,IN,OUT> codec,
long prefetch) |
ReactorPeer(Environment defaultEnv,
Dispatcher defaultDispatcher,
Codec<Buffer,IN,OUT> codec) |
ReactorPeer(Environment defaultEnv,
Dispatcher defaultDispatcher,
Codec<Buffer,IN,OUT> codec,
long prefetch) |
Constructor and Description |
---|
HttpChannel(Environment env,
long prefetch,
Dispatcher eventsDispatcher) |
HttpClient(Environment env,
Dispatcher dispatcher,
Codec<Buffer,IN,OUT> codec,
ClientSocketOptions options) |
HttpServer(Environment env,
Dispatcher dispatcher,
Codec<Buffer,IN,OUT> codec) |
Constructor and Description |
---|
NettyChannelStream(Environment env,
Codec<Buffer,IN,OUT> codec,
long prefetch,
Dispatcher eventsDispatcher,
io.netty.channel.Channel ioChannel) |
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. |
NettyHttpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
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. |
NettyTcpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Constructor and Description |
---|
NettyDatagramServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
NetworkInterface multicastInterface,
ServerSocketOptions options,
Codec<Buffer,IN,OUT> codec) |
Constructor and Description |
---|
ZeroMQChannelStream(Environment env,
long prefetch,
Dispatcher eventsDispatcher,
InetSocketAddress remoteAddress,
Codec<Buffer,IN,OUT> codec) |
Constructor and Description |
---|
ZeroMQ(Environment env) |
ZeroMQ(Environment env,
Dispatcher dispatcher) |
ZeroMQ(Environment env,
String dispatcher) |
ZeroMQTcpClient(Environment env,
Dispatcher eventsDispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
ZeroMQTcpServer(Environment env,
Dispatcher eventsDispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Constructor and Description |
---|
TcpClient(Environment env,
Dispatcher dispatcher,
Supplier<InetSocketAddress> connectAddress,
ClientSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
TcpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Constructor and Description |
---|
DatagramServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
NetworkInterface multicastInterface,
ServerSocketOptions options,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Method and Description |
---|---|
Environment |
Stream.getEnvironment()
Get the assigned
Environment . |
Environment |
Promise.getEnvironment() |
Modifier and Type | Method and Description |
---|---|
Stream<O> |
Stream.dispatchOn(Environment environment)
Assign a new Environment and its default Dispatcher to the returned Stream.
|
Stream<O> |
Stream.dispatchOn(Environment environment,
Dispatcher dispatcher)
Assign the a new Dispatcher and an Environment to the returned Stream.
|
Stream<O> |
Stream.env(Environment environment)
Assign an Environment to be provided to this Stream Subscribers
|
static <T> Promise<T> |
Promises.error(Environment env,
Dispatcher dispatcher,
Throwable error)
|
static <T> Promise<T> |
Promises.error(Environment env,
Throwable error)
|
static <T> Promise<T> |
Promises.prepare(Environment env)
Create a
Promise . |
static <T> Promise<T> |
Promises.ready(Environment env,
Dispatcher dispatcher)
Create a
Promise . |
Stream<O> |
Stream.subscribeOn(Environment environment)
Assign a new Dispatcher to handle upstream request to the returned Stream.
|
static <T> Promise<T> |
Promises.success(Environment env,
Dispatcher dispatcher,
T value)
|
static <T> Promise<T> |
Promises.success(Environment env,
T value)
|
static <T> Promise<T> |
Promises.task(Environment env,
Dispatcher dispatcher,
Supplier<T> supplier)
|
static <T> Promise<T> |
Promises.task(Environment env,
Supplier<T> supplier)
|
Constructor and Description |
---|
Promise(Dispatcher dispatcher,
Environment env)
Creates a new unfulfilled promise.
|
Promise(O value,
Dispatcher dispatcher,
Environment env)
Creates a new promise that has been fulfilled with the given
value . |
Promise(Throwable error,
Dispatcher dispatcher,
Environment env)
Creates a new promise that has failed with the given
error . |
Modifier and Type | Method and Description |
---|---|
Environment |
WindowShiftWhenAction.getEnvironment() |
Environment |
WindowAction.getEnvironment() |
Environment |
WindowWhenAction.getEnvironment() |
Environment |
WindowShiftAction.getEnvironment() |
Constructor and Description |
---|
WindowAction(Environment environment,
Dispatcher dispatcher,
int backlog) |
WindowAction(Environment environment,
Dispatcher dispatcher,
int backlog,
long timespan,
TimeUnit unit,
Timer timer) |
WindowShiftAction(Environment environment,
Dispatcher dispatcher,
int size,
int skip) |
WindowShiftAction(Environment environment,
Dispatcher dispatcher,
int size,
int skip,
long timespan,
long timeshift,
TimeUnit unit,
Timer timer) |
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) |
Modifier and Type | Method and Description |
---|---|
Environment |
GroupByAction.getEnvironment() |
Constructor and Description |
---|
GroupByAction(Environment environment,
Function<? super T,? extends K> fn,
Dispatcher dispatcher) |
Modifier and Type | Field and Description |
---|---|
protected Environment |
Broadcaster.environment |
Modifier and Type | Method and Description |
---|---|
static <T> Broadcaster<T> |
BehaviorBroadcaster.create(Environment env)
Build a Broadcaster, first broadcasting the most recent signal then ready to broadcast values with
Broadcaster.onNext(Object) ,
Broadcaster.onError(Throwable) , () . |
static <T> Broadcaster<T> |
SerializedBroadcaster.create(Environment env)
Build a Broadcaster, ready to broadcast values, ready to broadcast values with
Broadcaster.onNext(Object) ,
Broadcaster.onError(Throwable) , Broadcaster.onComplete() . |
static <T> Broadcaster<T> |
Broadcaster.create(Environment env)
Build a Broadcaster, ready to broadcast values with
Broadcaster.onNext(Object) ,
Broadcaster.onError(Throwable) , Broadcaster.onComplete() . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.create(Environment env,
Dispatcher dispatcher)
Build a Broadcaster, first broadcasting the most recent signal then
ready to broadcast values with
(Object) ,
Broadcaster.onError(Throwable) , Broadcaster.onComplete() . |
static <T> Broadcaster<T> |
Broadcaster.create(Environment env,
Dispatcher dispatcher)
Build a Broadcaster, ready to broadcast values with
(Object) ,
Broadcaster.onError(Throwable) , Broadcaster.onComplete() . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.first(T value,
Environment env)
Build a Broadcaster, first broadcasting the most recent signal then starting with the passed value,
then ready to broadcast values with
Broadcaster.onNext(Object) ,
Broadcaster.onError(Throwable) , () . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.first(T value,
Environment env,
Dispatcher dispatcher)
Build a Broadcaster, first broadcasting the most recent signal then starting with the passed value,
then ready to broadcast values with
(Object) ,
Broadcaster.onError(Throwable) , Broadcaster.onComplete() . |
Constructor and Description |
---|
Broadcaster(Environment environment,
Dispatcher dispatcher,
long capacity)
INTERNAL
|
Modifier and Type | Method and Description |
---|---|
Environment |
LiftStream.getEnvironment() |
Constructor and Description |
---|
BarrierStream(Environment env) |
BarrierStream(Environment env,
Dispatcher dispatcher) |
Copyright © 2016. All rights reserved.