Package | Description |
---|---|
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 |
Modifier and Type | Class and Description |
---|---|
class |
ReactorClient<IN,OUT,CONN extends ChannelStream<IN,OUT>>
A network-aware client that will publish its connection once available to the
ReactorChannelHandler passed. |
class |
ReactorPeer<IN,OUT,CONN extends ChannelStream<IN,OUT>>
Abstract base class that implements common functionality shared by clients and servers.
|
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>> |
Modifier and Type | Method and Description |
---|---|
static <E,IN,OUT> E |
NetStreams.delegate(ChannelStream<IN,OUT> channelStream)
Utils to read the ChannelStream underlying channel
|
static <E,IN,OUT> E |
NetStreams.delegate(ChannelStream<IN,OUT> channelStream,
Class<E> clazz) |
Modifier and Type | Class and Description |
---|---|
class |
HttpChannel<IN,OUT>
A Request/Response
ChannelStream extension that provides for several helpers to control HTTP behavior and
observe its metadata. |
Modifier and Type | Class and Description |
---|---|
class |
NettyChannelStream<IN,OUT>
ReactorChannel implementation that delegates to Netty. |
Modifier and Type | Field and Description |
---|---|
protected ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> |
NettyChannelHandlerBridge.handler |
Modifier and Type | Method and Description |
---|---|
ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> |
NettyChannelHandlerBridge.getHandler() |
Constructor and Description |
---|
NettyChannelHandlerBridge(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
NettyChannelStream<IN,OUT> channelStream) |
Modifier and Type | Class and Description |
---|---|
class |
NettyHttpChannel<IN,OUT> |
Modifier and Type | Method and Description |
---|---|
protected void |
NettyHttpClient.bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
Object nativeChannel) |
protected void |
NettyHttpServer.bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
io.netty.channel.socket.SocketChannel nativeChannel) |
Constructor and Description |
---|
NettyHttpClientHandler(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
NettyChannelStream<IN,OUT> tcpStream) |
NettyHttpServerHandler(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
NettyChannelStream<IN,OUT> tcpStream) |
NettyHttpWSClientHandler(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
NettyChannelStream<IN,OUT> tcpStream,
io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker) |
Modifier and Type | Method and Description |
---|---|
protected void |
NettyTcpClient.bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
io.netty.channel.socket.SocketChannel nativeChannel) |
protected void |
NettyTcpServer.bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
io.netty.channel.socket.SocketChannel nativeChannel) |
protected Promise<Void> |
NettyTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
protected Promise<Void> |
NettyTcpServer.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
Reconnect reconnect) |
Modifier and Type | Method and Description |
---|---|
protected void |
NettyDatagramServer.bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
Object _ioChannel) |
protected Promise<Void> |
NettyDatagramServer.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> channelHandler) |
Modifier and Type | Class and Description |
---|---|
class |
ZeroMQChannelStream<IN,OUT> |
Modifier and Type | Method and Description |
---|---|
Promise<ChannelStream<T,T>> |
ZeroMQ.createClient(String addrs,
int socketType) |
Promise<ChannelStream<T,T>> |
ZeroMQ.createServer(String addrs,
int socketType) |
Promise<ChannelStream<T,T>> |
ZeroMQ.dealer(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.pull(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.push(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.reply(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.request(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.router(String addrs) |
Modifier and Type | Method and Description |
---|---|
protected Promise<Void> |
ZeroMQTcpServer.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
protected Promise<Void> |
ZeroMQTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
Copyright © 2016. All rights reserved.