java.lang.Object
- org.springframework.messaging.tcp.reactor.Reactor2TcpConnection

Type Parameters:
P - the payload type of messages read or written to the TCP stream.
All Implemented Interfaces:
Closeable, AutoCloseable, TcpConnection
```
public class Reactor2TcpConnection
extends Object
implements TcpConnection
```
An implementation of TcpConnection based on the TCP client support of the Reactor project.
Since:
4.2
Author:
Rossen Stoyanchev

Constructor Summary
Constructors
Constructor Description
Reactor2TcpConnection(reactor.io.net.ChannelStream<Message,Message> channelStream, reactor.rx.Promise<Void> closePromise)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`	Close the connection.
`void`	`onReadInactivity(Runnable runnable, long inactivityDuration)`	Register a task to invoke after a period of read inactivity.
`void`	`onWriteInactivity(Runnable runnable, long inactivityDuration)`	Register a task to invoke after a period of write inactivity.
`ListenableFuture<Void>`	`send(Message<P> message)`	Send the given message.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
 - Reactor2TcpConnection
```
public Reactor2TcpConnection(reactor.io.net.ChannelStream<Message,Message> channelStream,
 reactor.rx.Promise<Void> closePromise)
```
- Method Detail
 - send
```
public ListenableFuture<Void> send(Message message)
```
 Description copied from interface: TcpConnection
 Send the given message.
 Specified by:
 send in interface TcpConnection
 Parameters:
 message - the message
 Returns:
 a ListenableFuture that can be used to determine when and if the message was successfully sent
 - onReadInactivity
```
public void onReadInactivity(Runnable runnable,
 long inactivityDuration)
```
 Description copied from interface: TcpConnection
 Register a task to invoke after a period of read inactivity.
 Specified by:
 onReadInactivity in interface TcpConnection
 Parameters:
 runnable - the task to invoke
 inactivityDuration - the amount of inactive time in milliseconds
 - onWriteInactivity
```
public void onWriteInactivity(Runnable runnable,
 long inactivityDuration)
```
 Description copied from interface: TcpConnection
 Register a task to invoke after a period of write inactivity.
 Specified by:
 onWriteInactivity in interface TcpConnection
 Parameters:
 runnable - the task to invoke
 inactivityDuration - the amount of inactive time in milliseconds
 - close
```
public void close()
```
 Description copied from interface: TcpConnection
 Close the connection.
 Specified by:
 close in interface AutoCloseable
 Specified by:
 close in interface Closeable
 Specified by:
 close in interface TcpConnection

Class Reactor2TcpConnection<P>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Reactor2TcpConnection

Method Detail

send

onReadInactivity

onWriteInactivity

close