我们希望在 akka 流关闭时完成以下任务
我们有以下代码用于关闭我们的 Actor 系统(Akka 2.4)。
try {
Await.ready(actorSystem.terminate(), sleepSeconds.seconds)
} catch {
case ex: Throwable => log.error("Failed to terminate actor system", ex)
}
我正在尝试理解 akka 文档,但我不清楚我们是否需要单独关闭物化器(对于我们的 akka 流)?我们在这里有一个关于物化器的方法和一个关于 Actor 系统的方法。
或者换句话说,我们应该采取什么惯用的操作步骤来干净/优雅地关闭我们的 akka 流。