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.
Return the path of the Akka actor giving access to the channel endpoint
Return the path of the Akka actor giving access to the channel endpoint
The path allows to (remotely) proxy the channel endpoint, via $.apply.
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)
.
Actor-based input channel endpoint, usually created through the companion object or via ActorChannel.factory.