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.