Package akka.actor.dungeon
Interface ReceiveTimeout
-
public interface ReceiveTimeoutINTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.Tuple2<scala.concurrent.duration.Duration,Cancellable>cancelReceiveTimeoutIfNeeded(java.lang.Object message)voidcancelReceiveTimeoutTask()voidcheckReceiveTimeout(boolean reschedule)voidcheckReceiveTimeoutIfNeeded(java.lang.Object message, scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)Called after `ActorCell.receiveMessage` or `ActorCell.autoReceiveMessage`.booleanhasTimeoutData()booleanmessageMarkedToNotInfluenceTimeout(java.lang.Object message)scala.concurrent.duration.DurationreceiveTimeout()booleanreceiveTimeoutChanged(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)voidreceiveTimeoutData_$eq(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> x$1)voidrescheduleReceiveTimeout(scala.concurrent.duration.FiniteDuration f)voidsetReceiveTimeout(scala.concurrent.duration.Duration timeout)
-
-
-
Method Detail
-
receiveTimeoutData_$eq
void receiveTimeoutData_$eq(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> x$1)
-
receiveTimeout
scala.concurrent.duration.Duration receiveTimeout()
-
setReceiveTimeout
void setReceiveTimeout(scala.concurrent.duration.Duration timeout)
-
checkReceiveTimeoutIfNeeded
void checkReceiveTimeoutIfNeeded(java.lang.Object message, scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)Called after `ActorCell.receiveMessage` or `ActorCell.autoReceiveMessage`.
-
checkReceiveTimeout
void checkReceiveTimeout(boolean reschedule)
-
rescheduleReceiveTimeout
void rescheduleReceiveTimeout(scala.concurrent.duration.FiniteDuration f)
-
hasTimeoutData
boolean hasTimeoutData()
-
receiveTimeoutChanged
boolean receiveTimeoutChanged(scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> beforeReceive)
-
cancelReceiveTimeoutIfNeeded
scala.Tuple2<scala.concurrent.duration.Duration,Cancellable> cancelReceiveTimeoutIfNeeded(java.lang.Object message)
-
cancelReceiveTimeoutTask
void cancelReceiveTimeoutTask()
-
messageMarkedToNotInfluenceTimeout
boolean messageMarkedToNotInfluenceTimeout(java.lang.Object message)
-
-