Interface TcpConnection<P>
- Type Parameters:
P- the type of payload for outboundMessages
- All Superinterfaces:
AutoCloseable,Closeable
- All Known Implementing Classes:
Reactor2TcpConnection
public interface TcpConnection<P> extends Closeable
A contract for sending messages and managing a TCP connection.- Since:
- 4.0
- Author:
- Rossen Stoyanchev
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidclose()Close the connection.voidonReadInactivity(Runnable runnable, long duration)Register a task to invoke after a period of read inactivity.voidonWriteInactivity(Runnable runnable, long duration)Register a task to invoke after a period of write inactivity.ListenableFuture<Void>send(Message<P> message)Send the given message.
Method Detail
send
ListenableFuture<Void> send(Message<P> message)
Send the given message.- Parameters:
message- the message- Returns:
- a ListenableFuture that can be used to determine when and if the message was successfully sent
onReadInactivity
void onReadInactivity(Runnable runnable, long duration)
Register a task to invoke after a period of read inactivity.- Parameters:
runnable- the task to invokeduration- the amount of inactive time in milliseconds
onWriteInactivity
void onWriteInactivity(Runnable runnable, long duration)
Register a task to invoke after a period of write inactivity.- Parameters:
runnable- the task to invokeduration- the amount of inactive time in milliseconds
close
void close()
Close the connection.- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable