org.springframework.messaging.tcp.reactor

Class ReactorNettyTcpClient.ReactorNettyHandler

java.lang.Object

org.springframework.messaging.tcp.reactor.ReactorNettyTcpClient.ReactorNettyHandler

All Implemented Interfaces:

java.util.function.BiFunction<NettyInbound,NettyOutbound,<any>>

Enclosing class:

ReactorNettyTcpClient<P>

private class ReactorNettyTcpClient.ReactorNettyHandler
extends java.lang.Object
implements java.util.function.BiFunction<NettyInbound,NettyOutbound,<any>>

Field Summary

Fields

Modifier and Type	Field and Description
private TcpConnectionHandler<P>	connectionHandler

Constructor Summary

Constructors

Constructor and Description
ReactorNettyHandler(TcpConnectionHandler<P> handler)

Method Summary

Modifier and Type	Method and Description
<any>	apply(NettyInbound inbound, NettyOutbound outbound)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Field Detail

connectionHandler

private final TcpConnectionHandler<P> connectionHandler

Constructor Detail

ReactorNettyHandler

ReactorNettyHandler(TcpConnectionHandler<P> handler)

Method Detail

apply

public <any> apply(NettyInbound inbound,
                   NettyOutbound outbound)

Specified by:

apply in interface java.util.function.BiFunction<NettyInbound,NettyOutbound,<any>>