class org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler extends java.lang.Object implements reactor.io.net.ReactorChannelHandler
{
private final org.springframework.messaging.tcp.TcpConnectionHandler connectionHandler;
private final java.lang.Runnable cleanupTask;
public void <init>(org.springframework.messaging.tcp.TcpConnectionHandler, java.lang.Runnable)
{
org.springframework.messaging.tcp.TcpConnectionHandler v;
java.lang.Runnable v;
org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler v;
v := @this: org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler;
v := @parameter: org.springframework.messaging.tcp.TcpConnectionHandler;
v := @parameter: java.lang.Runnable;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler: org.springframework.messaging.tcp.TcpConnectionHandler connectionHandler> = v;
v.<org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler: java.lang.Runnable cleanupTask> = v;
return;
}
public org.reactivestreams.Publisher apply(reactor.io.net.ChannelStream)
{
org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler v;
org.springframework.messaging.tcp.TcpConnectionHandler v;
reactor.io.net.ChannelStream v;
reactor.rx.Stream v;
org.springframework.messaging.tcp.reactor.Reactor2TcpConnection v;
reactor.rx.Promise v;
org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler$1 v;
org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler$2 v;
v := @this: org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler;
v := @parameter: reactor.io.net.ChannelStream;
v = staticinvoke <reactor.rx.Promises: reactor.rx.Promise prepare()>();
v = v.<org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler: org.springframework.messaging.tcp.TcpConnectionHandler connectionHandler>;
v = new org.springframework.messaging.tcp.reactor.Reactor2TcpConnection;
specialinvoke v.<org.springframework.messaging.tcp.reactor.Reactor2TcpConnection: void <init>(reactor.io.net.ChannelStream,reactor.rx.Promise)>(v, v);
interfaceinvoke v.<org.springframework.messaging.tcp.TcpConnectionHandler: void afterConnected(org.springframework.messaging.tcp.TcpConnection)>(v);
v = new org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler$2;
specialinvoke v.<org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler$2: void <init>(org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler)>(v);
v = virtualinvoke v.<reactor.io.net.ChannelStream: reactor.rx.Stream finallyDo(reactor.fn.Consumer)>(v);
v = new org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler$1;
specialinvoke v.<org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler$1: void <init>(org.springframework.messaging.tcp.reactor.Reactor2TcpClient$MessageChannelStreamHandler)>(v);
virtualinvoke v.<reactor.rx.Stream: reactor.rx.action.Control consume(reactor.fn.Consumer)>(v);
return v;
}
}