Read data from in, deserialize an object and return it.
Read data from in, deserialize an object and return it.
Exception if a deserialization error occurs.
Serialize an object and write it into out.
Serialize an object and write it into out.
Object to serialize.
Close in and out streams.
Close in and out streams.
You could derive this method to perform additional cleanup
when closing the StreamManager.
Read data from in, deserialize an object and return it.
Read data from in, deserialize an object and return it.
Maximum wait time
Execution context where an internal Future will run
Exception if a deserialization error occurs.
java.util.concurrent.TimeoutException if after waiting for atMost, no message arrives
Create a pair of I/O stream-based channel endpoints,
reading from in and writing to out.
Create a pair of I/O stream-based channel endpoints,
reading from in and writing to out.
Execution context for internal Promise/Future handling
Alias for close.
Alias for close.
Base class for stream management and (de)serialization of messages.