private static class Reactor2TcpClient.MessageChannelStreamHandler<P>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private java.lang.Runnable |
cleanupTask |
private TcpConnectionHandler<P> |
connectionHandler |
Constructor and Description |
---|
MessageChannelStreamHandler(TcpConnectionHandler<P> connectionHandler,
java.lang.Runnable cleanupTask) |
Modifier and Type | Method and Description |
---|---|
<any> |
apply(<any> channelStream) |
private final TcpConnectionHandler<P> connectionHandler
private final java.lang.Runnable cleanupTask
public MessageChannelStreamHandler(TcpConnectionHandler<P> connectionHandler, java.lang.Runnable cleanupTask)