spring-framework / org.springframework.messaging.tcp.reactor / ReactorNettyTcpConnection

ReactorNettyTcpConnection

open class ReactorNettyTcpConnection<P : Any> : TcpConnection<P>

Reactor Netty based implementation of TcpConnection.

Author
Rossen Stoyanchev

Since
5.0

Constructors

<init>

 ReactorNettyTcpConnection(inbound: NettyInbound, outbound: NettyOutbound, codec: ReactorNettyCodec<P>, closeProcessor: DirectProcessor<Void>)

Functions

close

 open fun close(): Unit

onReadInactivity

 open fun onReadInactivity(runnable: Runnable, inactivityDuration: Long): Unit

onWriteInactivity

 open fun onWriteInactivity(runnable: Runnable, inactivityDuration: Long): Unit

send

 open fun send(message: Message<P>): ListenableFuture<Void>