Modifier and Type	Class and Description
pack-priv static class	ServerTransportConfig.ServerTransportDoOn
pack-priv static class	ServerTransportConfig.ServerTransportDoOnConnection

Modifier and Type	Field and Description
pack-priv Map<AttributeKey<?>, ?>	childAttrs
pack-priv ConnectionObserver	childObserver
pack-priv Map<ChannelOption<?>, ?>	childOptions
pack-priv Consumer<? super CONF>	doOnBind
pack-priv Consumer<? super DisposableServer>	doOnBound
pack-priv Consumer<? super Connection>	doOnConnection
pack-priv Consumer<? super DisposableServer>	doOnUnbound

Access	Constructor and Description
protected	ServerTransportConfig(Map<ChannelOption<?>, ?> default options for the selector options, Map<ChannelOption<?>, ?> default options for each connected channel childOptions, Supplier<? extends SocketAddress> the local address bindAddress) Default ServerTransportConfig with options.
protected	ServerTransportConfig(ServerTransportConfig<CONF> parent)

Method Summary

Modifier and Type	Method and Description
protected Class<? extends Channel>	channelType(boolean true if `io.netty.channel.unix.DomainSocketChannel` or `io.netty.channel.unix.ServerDomainSocketChannel` is needed, false otherwise isDomainSocket) Implements abstract reactor.netty.transport.TransportConfig.channelType. Return the channel type this configuration is associated with, it can be one of the following.
public final Map<AttributeKey<?>, ?>	Returns: the read-only default channel attributes for each remote connection childAttributes() Return the read-only default channel attributes for each remote connection.
pack-priv final EventLoopGroup	Returns: the configured `EventLoopGroup` used for the remote connection. childEventLoopGroup() Return the configured `EventLoopGroup` used for the remote connection.
public final ConnectionObserver	Returns: the configured `ConnectionObserver` if any or `ConnectionObserver#emptyListener()` for each remote connection childObserver() Return the configured `ConnectionObserver` if any or `ConnectionObserver#emptyListener()` for each remote connection.
public final Map<ChannelOption<?>, ?>	Returns: the read-only `ChannelOption` map for each remote connection childOptions() Return the read-only `ChannelOption` map for each remote connection.
protected ConnectionObserver	Returns: the configured child lifecycle `ConnectionObserver` if any or `ConnectionObserver#emptyListener()` defaultChildObserver() Return the configured child lifecycle `ConnectionObserver` if any or `ConnectionObserver#emptyListener()`.
protected ConnectionObserver	defaultConnectionObserver() Implements abstract reactor.netty.transport.TransportConfig.defaultConnectionObserver. Return the configured default `ConnectionObserver`.
protected ChannelPipelineConfigurer	defaultOnChannelInit() Implements abstract reactor.netty.transport.TransportConfig.defaultOnChannelInit. Return the default callback if any or `ChannelPipelineConfigurer#emptyConfigurer()`.
public final Consumer<? super CONF>	Returns: the configured callback or null doOnBind() Return the configured callback or null.
public final Consumer<? super DisposableServer>	Returns: the configured callback or null doOnBound() Return the configured callback or null.
public final Consumer<? super Connection>	Returns: the configured callback or null doOnConnection() Return the configured callback or null.
public final Consumer<? super DisposableServer>	Returns: the configured callback or null doOnUnbound() Return the configured callback or null.
protected final EventLoopGroup	eventLoopGroup() Implements abstract reactor.netty.transport.TransportConfig.eventLoopGroup. Return the configured `EventLoopGroup`.

Field Detail

childAttrs	back to summary
pack-priv Map<AttributeKey<?>, ?> childAttrs

childObserver	back to summary
pack-priv ConnectionObserver childObserver

childOptions	back to summary
pack-priv Map<ChannelOption<?>, ?> childOptions

doOnBind	back to summary
pack-priv Consumer<? super CONF> doOnBind

doOnBound	back to summary
pack-priv Consumer<? super DisposableServer> doOnBound

doOnConnection	back to summary
pack-priv Consumer<? super Connection> doOnConnection

doOnUnbound	back to summary
pack-priv Consumer<? super DisposableServer> doOnUnbound

Constructor Detail

ServerTransportConfig	back to summary
protected ServerTransportConfig(Map<ChannelOption<?>, ?> options, Map<ChannelOption<?>, ?> childOptions, Supplier<? extends SocketAddress> bindAddress) Default ServerTransportConfig with options. Parameters options:Map<ChannelOption<?>, ?> default options for the selector childOptions:Map<ChannelOption<?>, ?> default options for each connected channel bindAddress:Supplier<? extends SocketAddress> the local address

ServerTransportConfig

back to summary

protected ServerTransportConfig(Map<ChannelOption<?>, ?> options, Map<ChannelOption<?>, ?> childOptions, Supplier<? extends SocketAddress> bindAddress)

Default ServerTransportConfig with options.

Parameters

options:Map<ChannelOption<?>, ?>: default options for the selector
childOptions:Map<ChannelOption<?>, ?>: default options for each connected channel
bindAddress:Supplier<? extends SocketAddress>: the local address

ServerTransportConfig	back to summary
protected ServerTransportConfig(ServerTransportConfig<CONF> parent)

Method Detail

channelType back to summary

channelType	back to summary
protected Class<? extends Channel> channelType(boolean isDomainSocket) Implements abstract reactor.netty.transport.TransportConfig.channelType. Doc from reactor.netty.transport.TransportConfig.channelType. Return the channel type this configuration is associated with, it can be one of the following. `io.netty.channel.socket.SocketChannel` `io.netty.channel.socket.ServerSocketChannel` `io.netty.channel.unix.DomainSocketChannel` `io.netty.channel.unix.ServerDomainSocketChannel` `io.netty.channel.socket.DatagramChannel` Parameters isDomainSocket:boolean true if `io.netty.channel.unix.DomainSocketChannel` or `io.netty.channel.unix.ServerDomainSocketChannel` is needed, false otherwise Returns:Class<? extends Channel> the channel type this configuration is associated with Annotations @Override

protected Class<? extends Channel> channelType(boolean isDomainSocket)

Implements abstract reactor.netty.transport.TransportConfig.channelType.

Doc from reactor.netty.transport.TransportConfig.channelType.

Return the channel type this configuration is associated with, it can be one of the following.

Parameters

isDomainSocket:boolean: true if io.netty.channel.unix.DomainSocketChannel or io.netty.channel.unix.ServerDomainSocketChannel is needed, false otherwise

Returns:Class<? extends Channel>

the channel type this configuration is associated with

Annotations

@Override

childAttributes	back to summary
public final Map<AttributeKey<?>, ?> childAttributes() Return the read-only default channel attributes for each remote connection. Returns:Map<AttributeKey<?>, ?> the read-only default channel attributes for each remote connection

childAttributes

back to summary

public final Map<AttributeKey<?>, ?> childAttributes()

Return the read-only default channel attributes for each remote connection.

Returns:Map<AttributeKey<?>, ?>: the read-only default channel attributes for each remote connection

childEventLoopGroup back to summary

childEventLoopGroup	back to summary
pack-priv final EventLoopGroup childEventLoopGroup() Return the configured `EventLoopGroup` used for the remote connection. Returns:EventLoopGroup the configured `EventLoopGroup` used for the remote connection.

pack-priv final EventLoopGroup childEventLoopGroup()

Return the configured EventLoopGroup used for the remote connection.

Returns:EventLoopGroup: the configured EventLoopGroup used for the remote connection.

childObserver back to summary

childObserver	back to summary
public final ConnectionObserver childObserver() Return the configured `ConnectionObserver` if any or `ConnectionObserver#emptyListener()` for each remote connection. Returns:ConnectionObserver the configured `ConnectionObserver` if any or `ConnectionObserver#emptyListener()` for each remote connection

public final ConnectionObserver childObserver()

Return the configured ConnectionObserver if any or ConnectionObserver#emptyListener() for each remote connection.

Returns:ConnectionObserver: the configured ConnectionObserver if any or ConnectionObserver#emptyListener() for each remote connection

childOptions back to summary

childOptions	back to summary
public final Map<ChannelOption<?>, ?> childOptions() Return the read-only `ChannelOption` map for each remote connection. Returns:Map<ChannelOption<?>, ?> the read-only `ChannelOption` map for each remote connection

public final Map<ChannelOption<?>, ?> childOptions()

Return the read-only ChannelOption map for each remote connection.

Returns:Map<ChannelOption<?>, ?>: the read-only ChannelOption map for each remote connection

defaultChildObserver back to summary

defaultChildObserver	back to summary
protected ConnectionObserver defaultChildObserver() Return the configured child lifecycle `ConnectionObserver` if any or `ConnectionObserver#emptyListener()`. Returns:ConnectionObserver the configured child lifecycle `ConnectionObserver` if any or `ConnectionObserver#emptyListener()`

protected ConnectionObserver defaultChildObserver()

Return the configured child lifecycle ConnectionObserver if any or ConnectionObserver#emptyListener().

Returns:ConnectionObserver: the configured child lifecycle ConnectionObserver if any or ConnectionObserver#emptyListener()

defaultConnectionObserver back to summary

defaultConnectionObserver	back to summary
protected ConnectionObserver defaultConnectionObserver() Implements abstract reactor.netty.transport.TransportConfig.defaultConnectionObserver. Doc from reactor.netty.transport.TransportConfig.defaultConnectionObserver. Return the configured default `ConnectionObserver`. Returns:ConnectionObserver the configured default `ConnectionObserver` Annotations @Override

protected ConnectionObserver defaultConnectionObserver()

Implements abstract reactor.netty.transport.TransportConfig.defaultConnectionObserver.

Doc from reactor.netty.transport.TransportConfig.defaultConnectionObserver.

Return the configured default ConnectionObserver.

Returns:ConnectionObserver

the configured default ConnectionObserver

Annotations

@Override

defaultOnChannelInit back to summary

defaultOnChannelInit	back to summary
protected ChannelPipelineConfigurer defaultOnChannelInit() Implements abstract reactor.netty.transport.TransportConfig.defaultOnChannelInit. Doc from reactor.netty.transport.TransportConfig.defaultOnChannelInit. Return the default callback if any or `ChannelPipelineConfigurer#emptyConfigurer()`. Returns:ChannelPipelineConfigurer the default callback if any or `ChannelPipelineConfigurer#emptyConfigurer()` Annotations @Override

protected ChannelPipelineConfigurer defaultOnChannelInit()

Implements abstract reactor.netty.transport.TransportConfig.defaultOnChannelInit.

Doc from reactor.netty.transport.TransportConfig.defaultOnChannelInit.

Return the default callback if any or ChannelPipelineConfigurer#emptyConfigurer().

Returns:ChannelPipelineConfigurer

the default callback if any or ChannelPipelineConfigurer#emptyConfigurer()

Annotations

@Override

doOnBind	back to summary
public final Consumer<? super CONF> doOnBind() Return the configured callback or null. Returns:Consumer<? super CONF> the configured callback or null Annotations @Nullable

doOnBind

back to summary

public final Consumer<? super CONF> doOnBind()

Return the configured callback or null.

Returns:Consumer<? super CONF>

the configured callback or null

Annotations

@Nullable

doOnBound	back to summary
public final Consumer<? super DisposableServer> doOnBound() Return the configured callback or null. Returns:Consumer<? super DisposableServer> the configured callback or null Annotations @Nullable

doOnBound

back to summary

public final Consumer<? super DisposableServer> doOnBound()

Return the configured callback or null.

Returns:Consumer<? super DisposableServer>

the configured callback or null

Annotations

@Nullable

doOnConnection	back to summary
public final Consumer<? super Connection> doOnConnection() Return the configured callback or null. Returns:Consumer<? super Connection> the configured callback or null Annotations @Nullable

doOnConnection

back to summary

public final Consumer<? super Connection> doOnConnection()

Return the configured callback or null.

Returns:Consumer<? super Connection>

the configured callback or null

Annotations

@Nullable

doOnUnbound	back to summary
public final Consumer<? super DisposableServer> doOnUnbound() Return the configured callback or null. Returns:Consumer<? super DisposableServer> the configured callback or null Annotations @Nullable

doOnUnbound

back to summary

public final Consumer<? super DisposableServer> doOnUnbound()

Return the configured callback or null.

Returns:Consumer<? super DisposableServer>

the configured callback or null

Annotations

@Nullable

eventLoopGroup back to summary

eventLoopGroup	back to summary
protected final EventLoopGroup eventLoopGroup() Implements abstract reactor.netty.transport.TransportConfig.eventLoopGroup. Doc from reactor.netty.transport.TransportConfig.eventLoopGroup. Return the configured `EventLoopGroup`. Returns:EventLoopGroup the configured `EventLoopGroup` Annotations @Override

protected final EventLoopGroup eventLoopGroup()

Implements abstract reactor.netty.transport.TransportConfig.eventLoopGroup.

Doc from reactor.netty.transport.TransportConfig.eventLoopGroup.

Return the configured EventLoopGroup.

Returns:EventLoopGroup

the configured EventLoopGroup

Annotations

@Override

reactor.netty.transport back to summary

pack-priv final Class ServerTransportConfig.ServerTransportDoOn

Class Inheritance

extends Object
implements ConnectionObserver

java.lang.Object
reactor.netty.transport.ServerTransportConfig.ServerTransportDoOn

All Implemented Interfaces

reactor.netty.ConnectionObserver

Field Summary

Modifier and Type	Field and Description
pack-priv final Consumer<? super DisposableServer>	doOnBound
pack-priv final Consumer<? super DisposableServer>	doOnUnbound

Constructor Summary

Access	Constructor and Description
pack-priv	ServerTransportDoOn(Consumer<? super DisposableServer> doOnBound, Consumer<? super DisposableServer> doOnUnbound)

Method Summary

Modifier and Type	Method and Description
public void	onStateChange(Connection the connection reference connection, ConnectionObserver.State the new State newState) Implements reactor.netty.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response).

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

doOnBound	back to summary
pack-priv final Consumer<? super DisposableServer> doOnBound

doOnUnbound	back to summary
pack-priv final Consumer<? super DisposableServer> doOnUnbound

Constructor Detail

ServerTransportDoOn	back to summary
pack-priv ServerTransportDoOn(Consumer<? super DisposableServer> doOnBound, Consumer<? super DisposableServer> doOnUnbound)

Method Detail

onStateChange	back to summary
public void onStateChange(Connection connection, ConnectionObserver.State newState) Implements reactor.netty.ConnectionObserver.onStateChange. Doc from reactor.netty.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response). Parameters connection:Connection the connection reference newState:ConnectionObserver.State the new State Annotations @Override

onStateChange

back to summary

public void onStateChange(Connection connection, ConnectionObserver.State newState)

Implements reactor.netty.ConnectionObserver.onStateChange.

Doc from reactor.netty.ConnectionObserver.onStateChange.

React on connection state change (e.g. http request or response).

Parameters

connection:Connection: the connection reference
newState:ConnectionObserver.State: the new State

Annotations

@Override

reactor.netty.transport back to summary

pack-priv final Class ServerTransportConfig.ServerTransportDoOnConnection

Class Inheritance

extends Object
implements ConnectionObserver

java.lang.Object
reactor.netty.transport.ServerTransportConfig.ServerTransportDoOnConnection

All Implemented Interfaces

reactor.netty.ConnectionObserver

Field Summary

Modifier and Type	Field and Description
pack-priv final ChannelGroup	channelGroup
pack-priv final Consumer<? super Connection>	doOnConnection

Constructor Summary

Access	Constructor and Description
pack-priv	ServerTransportDoOnConnection(ChannelGroup channelGroup, Consumer<? super Connection> doOnConnection)

Method Summary

Modifier and Type	Method and Description
public void	onStateChange(Connection the connection reference connection, ConnectionObserver.State the new State newState) Implements reactor.netty.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response).

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

channelGroup	back to summary
pack-priv final ChannelGroup channelGroup

doOnConnection	back to summary
pack-priv final Consumer<? super Connection> doOnConnection

Constructor Detail

ServerTransportDoOnConnection	back to summary
pack-priv ServerTransportDoOnConnection(ChannelGroup channelGroup, Consumer<? super Connection> doOnConnection)

Method Detail

onStateChange	back to summary
public void onStateChange(Connection connection, ConnectionObserver.State newState) Implements reactor.netty.ConnectionObserver.onStateChange. Doc from reactor.netty.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response). Parameters connection:Connection the connection reference newState:ConnectionObserver.State the new State Annotations @Override @SuppressWarnings:FutureReturnValueIgnored

onStateChange

back to summary

public void onStateChange(Connection connection, ConnectionObserver.State newState)

Implements reactor.netty.ConnectionObserver.onStateChange.

Doc from reactor.netty.ConnectionObserver.onStateChange.

React on connection state change (e.g. http request or response).

Parameters

connection:Connection: the connection reference
newState:ConnectionObserver.State: the new State

Annotations

@Override
@SuppressWarnings:FutureReturnValueIgnored

public abstract Class ServerTransportConfig<CONF extends reactor.netty.transport.TransportConfig>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ServerTransportConfig.ServerTransportDoOn

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ServerTransportConfig.ServerTransportDoOnConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail