Package | Description |
---|---|
reactor.groovy.ext | |
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.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.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.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.stream.io |
Stream implementations that provide for IO access, for instance read/read-write persisting streams |
Modifier and Type | Method and Description |
---|---|
static <SRC,IN> Stream<IN> |
StreamExtensions.decode(org.reactivestreams.Publisher<? extends SRC> publisher,
Codec<SRC,IN,?> codec) |
Modifier and Type | Class and Description |
---|---|
class |
BufferCodec<IN,OUT>
Implementations of a BufferCodec are codec manipulating Buffer sources
|
class |
ByteArrayCodec
|
class |
DelimitedCodec<IN,OUT>
|
class |
FrameCodec
Codec for decoding data into length-field-based Frames . |
class |
JavaSerializationCodec<T>
Codec to transform Java objects into Buffers and visa-versa. |
class |
LengthFieldCodec<IN,OUT>
A codec that uses a length-field at the start of each chunk to denote the chunk's size.
|
class |
PassThroughCodec<SRC>
A simple
Codec that uses the source object as both input and output. |
class |
SerializationCodec<E,IN,OUT>
Abstract base class for
Codec Codecs that perform serialization of objects. |
class |
StringCodec |
Modifier and Type | Field and Description |
---|---|
static Codec<Buffer,Buffer,Buffer> |
StandardCodecs.PASS_THROUGH_CODEC |
Constructor and Description |
---|
DelimitedCodec(boolean stripDelimiter,
Codec<Buffer,IN,OUT> delegate)
Create a line-feed-delimited codec, using the given
Codec as a delegate. |
DelimitedCodec(byte delimiter,
boolean stripDelimiter,
Codec<Buffer,IN,OUT> delegate)
Create a delimited codec using the given delimiter and using the given
Codec
as a delegate. |
DelimitedCodec(Codec<Buffer,IN,OUT> delegate)
Create a line-feed-delimited codec, using the given
Codec as a delegate. |
LengthFieldCodec(Codec<Buffer,IN,OUT> delegate)
Create a length-field codec that reads the first integer as the length of the
remaining message.
|
LengthFieldCodec(int lengthFieldLength,
Codec<Buffer,IN,OUT> delegate)
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.
|
Modifier and Type | Class and Description |
---|---|
class |
CompressionCodec<IN,OUT> |
class |
GzipCodec<IN,OUT> |
class |
SnappyCodec<IN,OUT> |
Constructor and Description |
---|
CompressionCodec(Codec<Buffer,IN,OUT> delegate) |
GzipCodec(Codec<Buffer,IN,OUT> delegate) |
SnappyCodec(Codec<Buffer,IN,OUT> delegate) |
Modifier and Type | Class and Description |
---|---|
class |
JacksonJsonCodec<IN,OUT> |
class |
JsonCodec<IN,OUT>
A codec for decoding JSON into Java objects and encoding Java objects into JSON.
|
Modifier and Type | Class and Description |
---|---|
class |
KryoCodec<IN,OUT> |
class |
KryoPoolCodec<IN,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
ProtobufCodec<IN,OUT> |
Modifier and Type | Field and Description |
---|---|
protected Codec<Buffer,IN,OUT> |
Spec.PeerSpec.codec |
static Codec |
Spec.NOOP_CODEC |
Modifier and Type | Method and Description |
---|---|
Codec<Buffer,IN,OUT> |
ReactorPeer.getDefaultCodec()
Get the
Codec in use. |
Modifier and Type | Method and Description |
---|---|
S |
Spec.PeerSpec.codec(Codec<Buffer,IN,OUT> codec)
The
Codec to use to encode and decode data. |
Spec.TcpClientSpec<IN,OUT> |
Spec.TcpClientSpec.codec(Codec<Buffer,IN,OUT> codec)
The
Codec to use to encode and decode data. |
Spec.HttpClientSpec<IN,OUT> |
Spec.HttpClientSpec.codec(Codec<Buffer,IN,OUT> codec)
The
Codec to use to encode and decode data. |
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) |
Modifier and Type | Class and Description |
---|---|
class |
SyslogCodec
A coded for consuming syslog messages.
|
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
ZeroMQ<T> |
ZeroMQ.codec(Codec<Buffer,T,T> codec) |
Constructor and Description |
---|
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 |
---|---|
Codec<Buffer,T,T> |
ChronicleQueuePersistor.codec() |
Constructor and Description |
---|
ChronicleQueuePersistor(String basePath,
Codec<Buffer,T,T> codec,
boolean clearOnStart,
boolean deleteOnExit,
net.openhft.chronicle.ChronicleQueueBuilder config)
Create an
ChronicleQueuePersistor based on the given base path, encoder and decoder. |
Modifier and Type | Method and Description |
---|---|
PersistentQueueSpec<T> |
PersistentQueueSpec.codec(Codec<Buffer,T,T> codec) |
Modifier and Type | Method and Description |
---|---|
<V> Stream<V> |
Stream.decode(Codec<O,V,?> codec)
Transform a sequence of codec source elements into codec input elements through
decode(Publisher) |
static <SRC,IN> Stream<IN> |
IOStreams.decode(Codec<SRC,IN,?> codec,
org.reactivestreams.Publisher<? extends SRC> publisher)
|
<V> Stream<V> |
Stream.encode(Codec<V,?,O> codec)
Transform a sequence of codec output elements into codec source elements through
encode(Publisher) |
Modifier and Type | Field and Description |
---|---|
protected Codec<Buffer,K,K> |
ChronicleReaderStream.keyCodec |
protected Codec<Buffer,V,V> |
ChronicleReaderStream.valueCodec |
Modifier and Type | Method and Description |
---|---|
Codec<Buffer,K,K> |
ChronicleReaderStream.keyCodec() |
Codec<Buffer,V,V> |
ChronicleReaderStream.valueCodec() |
Constructor and Description |
---|
ChronicleReaderStream(String name,
net.openhft.chronicle.Chronicle chronicle,
Codec<Buffer,K,K> keyCodec,
Codec<Buffer,V,V> valueCodec) |
ChronicleReaderStream(String name,
net.openhft.chronicle.Chronicle chronicle,
Codec<Buffer,K,K> keyCodec,
Codec<Buffer,V,V> valueCodec) |
ChronicleStream(String name,
int messageSizeHint,
net.openhft.chronicle.Chronicle chronicle,
Codec<Buffer,K,K> keyCodec,
Codec<Buffer,V,V> valueCodec) |
ChronicleStream(String name,
int messageSizeHint,
net.openhft.chronicle.Chronicle chronicle,
Codec<Buffer,K,K> keyCodec,
Codec<Buffer,V,V> valueCodec) |
Copyright © 2017. All rights reserved.