StreamIn
Related Docs:
object StreamIn
| package lchannels
Wait for a message, pass it as argument to f, get the return value.
Wait for a message, pass it as argument to f, get the return value.
Once a message msg is received, this method returns f(msg).
Maximum wait time
java.lang.IllegalArgumentException if atMost is Duration.Undefined
java.lang.InterruptedException if the current thread is interrupted while waiting
java.util.concurrent.TimeoutException if after waiting for atMost, no message arrives
scala.util.control.NonFatal in case of other errors (e.g. deserialization or network issues)
Wait for a message or error, pass it as argument to f, get the return value.
Wait for a message or error, pass it as argument to f, get the return value.
Once a message msg is received, this method returns
f(Success(msg)). In case of errors, the method returns
f(Failure(exception)).
Maximum wait time
Return a future that will be completed when the channel endpoint receives a value, or incurs in an input error.
Return a future that will be completed when the channel endpoint receives a value, or incurs in an input error.
Receive and return a message, blocking until its arrival.
Receive and return a message, blocking until its arrival.
Maximum wait time
AlreadyUsed if the channel endpoint was already used for input
java.lang.IllegalArgumentException if atMost is Duration.Undefined
java.lang.InterruptedException if the current thread is interrupted while waiting
java.util.concurrent.TimeoutException if after waiting for atMost, no message arrives
scala.util.control.NonFatal in case of other errors (e.g. deserialization or network issues)
Receive and return a message, blocking until its arrival.
Receive and return a message, blocking until its arrival.
The default implementation of this method corresponds to atMost:* with an infinite timeout value.
AlreadyUsed if the channel endpoint was already used for input
java.lang.IllegalArgumentException if atMost is Duration.Undefined
java.lang.InterruptedException if the current thread is interrupted while waiting
java.util.concurrent.TimeoutException if after waiting for atMost, no message arrives
scala.util.control.NonFatal in case of other errors (e.g. deserialization or network issues)
Receive and return message, blocking until its arrival, or until a failure.
Receive and return message, blocking until its arrival, or until a failure.
Once a message msg is received, this method returnsSuccess(msg).
In case of errors, the method returns Failure(exception).
Maximum wait time
Receive and return message, blocking until its arrival, or until a failure.
Receive and return message, blocking until its arrival, or until a failure.
The default implementation of this method corresponds to atMost:* with an infinite timeout value.
Once a message msg is received, this method returnsSuccess(msg).
In case of errors, the method returns Failure(exception).
Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.