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.impl.netty.http | |
reactor.io.net.impl.netty.tcp | |
reactor.io.net.impl.zmq.tcp |
Modifier and Type | Field and Description |
---|---|
static Class<? extends TcpServer> |
NetStreams.DEFAULT_TCP_SERVER_TYPE |
Modifier and Type | Method and Description |
---|---|
protected TcpServer<IN,OUT> |
Spec.TcpServerSpec.configure(Dispatcher dispatcher,
Environment env) |
static TcpServer<Buffer,Buffer> |
NetStreams.tcpServer()
Bind a new TCP server to "loopback" on port 12012.
|
static <IN,OUT> TcpServer<IN,OUT> |
NetStreams.tcpServer(Class<? extends TcpServer> serverFactory,
Function<? super Spec.TcpServerSpec<IN,OUT>,? extends Spec.TcpServerSpec<IN,OUT>> configuringFunction)
Bind a new TCP server to the specified bind address and port.
|
static <IN,OUT> TcpServer<IN,OUT> |
NetStreams.tcpServer(Function<? super Spec.TcpServerSpec<IN,OUT>,? extends Spec.TcpServerSpec<IN,OUT>> configuringFunction)
Bind a new TCP server to the specified bind address and port.
|
static TcpServer<Buffer,Buffer> |
NetStreams.tcpServer(int port)
Bind a new TCP server to "loopback" on the given port.
|
static TcpServer<Buffer,Buffer> |
NetStreams.tcpServer(String bindAddress)
Bind a new TCP server to the given bind address on port 12012.
|
static TcpServer<Buffer,Buffer> |
NetStreams.tcpServer(String bindAddress,
int port)
Bind a new TCP server to the given bind address and port.
|
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> TcpServer<IN,OUT> |
NetStreams.tcpServer(Class<? extends TcpServer> serverFactory,
Function<? super Spec.TcpServerSpec<IN,OUT>,? extends Spec.TcpServerSpec<IN,OUT>> configuringFunction)
Bind a new TCP server to the specified bind address and port.
|
Modifier and Type | Field and Description |
---|---|
protected TcpServer<IN,OUT> |
NettyHttpServer.server |
Modifier and Type | Class and Description |
---|---|
class |
NettyTcpServer<IN,OUT>
A Netty-based
TcpServer implementation |
Modifier and Type | Class and Description |
---|---|
class |
ZeroMQTcpServer<IN,OUT> |
Copyright © 2016. All rights reserved.