Skip to content

Commit 29b7d22

Browse files
committed
Use duration converters for close()
1 parent 39276c9 commit 29b7d22

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

actor/src/main/scala/org/apache/pekko/actor/ActorSystem.scala

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ import scala.concurrent.{ Await, ExecutionContext, ExecutionContextExecutor, Fut
2424
import scala.concurrent.blocking
2525
import scala.concurrent.duration.Duration
2626
import scala.jdk.CollectionConverters._
27+
import scala.jdk.DurationConverters._
2728
import scala.jdk.FutureConverters._
2829
import scala.jdk.OptionConverters._
2930
import scala.util.{ Failure, Success, Try }
@@ -1102,10 +1103,8 @@ private[pekko] class ActorSystemImpl(
11021103

11031104
override def close(): Unit = {
11041105
terminate()
1105-
val duration =
1106-
Duration(settings.config.getDuration("pekko.coordinated-shutdown.close-actor-system-timeout").toMillis,
1107-
TimeUnit.MILLISECONDS)
1108-
Await.result(whenTerminated, duration)
1106+
Await.result(whenTerminated,
1107+
settings.config.getDuration("pekko.coordinated-shutdown.close-actor-system-timeout").toScala)
11091108
}
11101109

11111110
override private[pekko] def finalTerminate(): Unit = {

0 commit comments

Comments
 (0)