diff --git a/akka-actor/src/main/scala/akka/actor/FSM.scala b/akka-actor/src/main/scala/akka/actor/FSM.scala index a42066d0d2..51d0c290dc 100644 --- a/akka-actor/src/main/scala/akka/actor/FSM.scala +++ b/akka-actor/src/main/scala/akka/actor/FSM.scala @@ -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))) } diff --git a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala index e52fe741ea..a1721d2ffe 100644 --- a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala +++ b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala @@ -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