P - 送信メッセージのペイロードの型 public class ReactorNettyTcpConnection<P> extends ObjectSE implements TcpConnection<P>
TcpConnection の実装。| コンストラクターと説明 |
|---|
ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound, reactor.netty.NettyOutbound outbound, ReactorNettyCodec<P> codec, reactor.core.publisher.Sinks.Empty<VoidSE> completionSink) |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | close() 接続を閉じる。 |
void | onReadInactivity(RunnableSE runnable, long inactivityDuration) 一定の読み取り非アクティブ期間の後に呼び出すタスクを登録します。 |
void | onWriteInactivity(RunnableSE runnable, long inactivityDuration) 一定期間の書き込み非アクティブ後に呼び出されるタスクを登録します。 |
ListenableFuture<VoidSE> | send(Message<P> message) 指定されたメッセージを送信します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound,
reactor.netty.NettyOutbound outbound,
ReactorNettyCodec<P> codec,
reactor.core.publisher.Sinks.Empty<VoidSE> completionSink)public ListenableFuture<VoidSE> send(Message<P> message)
TcpConnectionTcpConnection<P> の send message - メッセージ public void onReadInactivity(RunnableSE runnable, long inactivityDuration)
TcpConnectionTcpConnection<P> の onReadInactivity runnable - 呼び出すタスク inactivityDuration - ミリ秒単位の非アクティブ時間 public void onWriteInactivity(RunnableSE runnable, long inactivityDuration)
TcpConnectionTcpConnection<P> の onWriteInactivity runnable - 呼び出すタスク inactivityDuration - ミリ秒単位の非アクティブ時間 public void close()
TcpConnectionCloseableSE の closeSE AutoCloseableSE の closeSE TcpConnection<P> の close