reactor.io.net

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>>

java.lang.Object

reactor.bus.spec.DispatcherComponentSpec<S,N>

reactor.io.net.Spec.PeerSpec<IN,OUT,CONN,S,N>

All Implemented Interfaces:

Supplier<N>

Direct Known Subclasses:

Spec.DatagramServerSpec, Spec.HttpServerSpec, Spec.TcpServerSpec

Enclosing interface:

Spec

public abstract 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>>
extends DispatcherComponentSpec<S,N>

Field Summary

Fields

Modifier and Type	Field and Description
protected Codec<Buffer,IN,OUT>	codec
protected InetSocketAddress	listenAddress
protected ServerSocketOptions	options

Constructor Summary

Constructors

Constructor and Description
PeerSpec()

Method Summary

Modifier and Type	Method and Description
S	codec(Codec<Buffer,IN,OUT> codec) The Codec to use to encode and decode data.
S	listen(InetSocketAddress listenAddress) The InetSocketAddress on which this server should listen.
S	listen(int port) The port on which this server should listen, assuming it should bind to all available addresses.
S	listen(String host, int port) The host and port on which this server should listen.
S	options(ServerSocketOptions options) Set the common ServerSocketOptions for channels made in this server.
S	rawData(boolean israw) Bypass any Reactor Buffer encoding for received data

Methods inherited from class reactor.bus.spec.DispatcherComponentSpec

configure, defaultDispatcher, dispatcher, dispatcher, env, get, synchronousDispatcher

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

options

protected ServerSocketOptions options

listenAddress

protected InetSocketAddress listenAddress

codec

protected Codec<Buffer,IN,OUT> codec

Constructor Detail

PeerSpec

public PeerSpec()

Method Detail

options

public S options(@Nonnull
                 ServerSocketOptions options)

Set the common ServerSocketOptions for channels made in this server.

Parameters:

options - The options to set when new channels are made.

Returns:

this

listen

public S listen(int port)

The port on which this server should listen, assuming it should bind to all available addresses.

Parameters:

port - The port to listen on.

Returns:

this

listen

public S listen(String host,
                int port)

The host and port on which this server should listen.

Parameters:

host - The host to bind to.

port - The port to listen on.

Returns:

this

listen

public S listen(InetSocketAddress listenAddress)

The InetSocketAddress on which this server should listen.

Parameters:

listenAddress - the listen address

Returns:

this

codec

public S codec(@Nonnull
               Codec<Buffer,IN,OUT> codec)

The Codec to use to encode and decode data.

Parameters:

codec - The codec to use.

Returns:

this

rawData

public S rawData(boolean israw)

Bypass any Reactor Buffer encoding for received data

Parameters:

israw - to enable raw data transfer from the server (e.g. ByteBuf from Netty).

Returns:

this