unbreak the akka-actor-nightly build
This commit is contained in:
parent
397006918a
commit
79c9cdd98e
2 changed files with 2 additions and 2 deletions
|
|
@ -597,7 +597,7 @@ trait FSM[S, D] extends Listeners with ActorLogging {
|
|||
val timeout = if (currentState.timeout.isDefined) currentState.timeout else stateTimeouts(currentState.stateName)
|
||||
if (timeout.isDefined) {
|
||||
val t = timeout.get
|
||||
if (t.finite_? && t.length >= 0) {
|
||||
if (t.isFinite && t.length >= 0) {
|
||||
import context.dispatcher
|
||||
timeoutFuture = Some(context.system.scheduler.scheduleOnce(t, self, TimeoutMarker(generation)))
|
||||
}
|
||||
|
|
|
|||
|
|
@ -568,7 +568,7 @@ trait TestKitBase {
|
|||
val message =
|
||||
if (max == 0.seconds) {
|
||||
queue.pollFirst
|
||||
} else if (max.finite_?) {
|
||||
} else if (max.isFinite) {
|
||||
queue.pollFirst(max.length, max.unit)
|
||||
} else {
|
||||
queue.takeFirst
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue