P
- the payload type of messages read or written to the TCP stream.public class Reactor2TcpConnection<P> extends java.lang.Object implements TcpConnection<P>
TcpConnection
based on the TCP client support of the Reactor project.Modifier and Type | Field and Description |
---|---|
private <any> |
channelStream |
private <any> |
closePromise |
Constructor and Description |
---|
Reactor2TcpConnection(<any> channelStream,
<any> closePromise) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the connection.
|
void |
onReadInactivity(java.lang.Runnable runnable,
long inactivityDuration)
Register a task to invoke after a period of read inactivity.
|
void |
onWriteInactivity(java.lang.Runnable runnable,
long inactivityDuration)
Register a task to invoke after a period of write inactivity.
|
ListenableFuture<java.lang.Void> |
send(Message<P> message)
Send the given message.
|
private final <any> channelStream
private final <any> closePromise
public Reactor2TcpConnection(<any> channelStream, <any> closePromise)
public ListenableFuture<java.lang.Void> send(Message<P> message)
TcpConnection
send
in interface TcpConnection<P>
message
- the messagepublic void onReadInactivity(java.lang.Runnable runnable, long inactivityDuration)
TcpConnection
onReadInactivity
in interface TcpConnection<P>
runnable
- the task to invokeinactivityDuration
- the amount of inactive time in millisecondspublic void onWriteInactivity(java.lang.Runnable runnable, long inactivityDuration)
TcpConnection
onWriteInactivity
in interface TcpConnection<P>
runnable
- the task to invokeinactivityDuration
- the amount of inactive time in millisecondspublic void close()
TcpConnection
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface TcpConnection<P>