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.tcp |
Modifier and Type | Field and Description |
---|---|
static ReactorChannelHandler |
ReactorClient.PING |
Modifier and Type | Method and Description |
---|---|
protected abstract Promise<Void> |
ReactorPeer.doStart(ReactorChannelHandler<IN,OUT,CONN> handler) |
protected abstract Stream<Tuple2<InetSocketAddress,Integer>> |
ReactorClient.doStart(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect) |
Promise<Void> |
ReactorPeer.start(ReactorChannelHandler<IN,OUT,CONN> handler)
Start this Peer.
|
Stream<Tuple2<InetSocketAddress,Integer>> |
ReactorClient.start(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect)
Open a channel to the configured address and return a
Stream that will be populated
by the ChannelStream every time a connection or reconnection is made. |
Modifier and Type | Field and Description |
---|---|
protected Registry<HttpChannel,ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>>> |
HttpServer.routedWriters |
Modifier and Type | Method and Description |
---|---|
HttpServer<IN,OUT> |
HttpServer.delete(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP DELETE on the passed path to be used as a routing condition.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.delete(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP DELETE the passed URL.
|
HttpServer<IN,OUT> |
HttpServer.get(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP GET on the passed path to be used as a routing condition.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.get(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP GET the passed URL.
|
HttpServer<IN,OUT> |
HttpServer.post(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP POST on the passed path to be used as a routing condition.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.post(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP POST the passed URL.
|
HttpServer<IN,OUT> |
HttpServer.put(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP PUT on the passed path to be used as a routing condition.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.put(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP PUT the passed URL.
|
abstract Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Use the passed HTTP method to send to the given URL.
|
HttpServer<IN,OUT> |
HttpServer.route(Selector<HttpChannel> condition,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> serviceFunction)
Register an handler for the given Selector condition, incoming connections will query the internal registry
to invoke the matching handlers.
|
HttpServer<IN,OUT> |
HttpServer.ws(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for WebSocket on the passed path to be used as a routing condition.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.ws(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
WebSocket to the passed URL.
|
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 | 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) |
protected Promise<Void> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
protected Promise<Void> |
NettyHttpServer.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler,
Reconnect reconnect) |
Promise<? extends HttpChannel<IN,OUT>> |
NettyHttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
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 | 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) |
protected Stream<Tuple2<InetSocketAddress,Integer>> |
ZeroMQTcpClient.doStart(ReactorChannelHandler handler,
Reconnect reconnect) |
Copyright © 2016. All rights reserved.