java.lang.Object
- org.springframework.messaging.tcp.reactor.ReactorNettyTcpConnection

类型参数:
P - the type of payload for outbound messages
所有已实现的接口:
Closeable, AutoCloseable, TcpConnection
```
public class ReactorNettyTcpConnection
extends Object
implements TcpConnection
```
Reactor Netty based implementation of TcpConnection.
从以下版本开始:
5.0
作者:
Rossen Stoyanchev

构造器概要

构造器
构造器	说明
`ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound, reactor.netty.NettyOutbound outbound, ReactorNettyCodec<P> codec, reactor.core.publisher.DirectProcessor<Void> closeProcessor)`

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`void`	`close()`	Close the connection.
`void`	`onReadInactivity(Runnable runnable, long inactivityDuration)`	Register a task to invoke after a period of read inactivity.
`void`	`onWriteInactivity(Runnable runnable, long inactivityDuration)`	Register a task to invoke after a period of write inactivity.
`ListenableFuture<Void>`	`send(Message<P> message)`	Send the given message.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
 - ReactorNettyTcpConnection
```
public ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound,
 reactor.netty.NettyOutbound outbound,
 ReactorNettyCodec codec,
 reactor.core.publisher.DirectProcessor<Void> closeProcessor)
```
- 方法详细资料
 - send
```
public ListenableFuture<Void> send(Message message)
```
 从接口复制的说明: TcpConnection
 Send the given message.
 指定者:
 send 在接口中 TcpConnection
 参数:
 message - the message
 返回:
 a ListenableFuture that can be used to determine when and if the message was successfully sent
 - onReadInactivity
```
public void onReadInactivity(Runnable runnable,
 long inactivityDuration)
```
 从接口复制的说明: TcpConnection
 Register a task to invoke after a period of read inactivity.
 指定者:
 onReadInactivity 在接口中 TcpConnection
 参数:
 runnable - the task to invoke
 inactivityDuration - the amount of inactive time in milliseconds
 - onWriteInactivity
```
public void onWriteInactivity(Runnable runnable,
 long inactivityDuration)
```
 从接口复制的说明: TcpConnection
 Register a task to invoke after a period of write inactivity.
 指定者:
 onWriteInactivity 在接口中 TcpConnection
 参数:
 runnable - the task to invoke
 inactivityDuration - the amount of inactive time in milliseconds
 - close
```
public void close()
```
 从接口复制的说明: TcpConnection
 Close the connection.
 指定者:
 close 在接口中 AutoCloseable
 指定者:
 close 在接口中 Closeable
 指定者:
 close 在接口中 TcpConnection

类 ReactorNettyTcpConnection<P>

构造器概要

方法概要

从类继承的方法 java.lang.Object

构造器详细资料

ReactorNettyTcpConnection

方法详细资料

send

onReadInactivity

onWriteInactivity

close