akka - 关闭 Akka 流以进行资源清理

Question

使用 Akka Streams 时，是否有任何方法可以关闭/关闭资源清理不再需要的流？

编辑：当源由无限流组成时，它可能永远不会完成，我想在完成源之前停止它。

示例用法：

Source.from(publisher)
      .map((p) -> p)
      .to(Sink.ignore())
      .run(materializer)

有没有办法关闭流？

Answer 1

您可以在一段时间后在 ActorMaterializerStream上独立运行并调用 shutdown：ActorMaterializer

val actorSystem = ActorSystem()

val temporaryStream = {

  val localMat = ActorMaterializer()(actorSystem)

  import actorSystem.dispatcher
  actorSystem.scheduler.scheduleOnce(10 minutes) { localMat.shutdown() }

  Source.from(publisher)
        .map((p) -> p)
        .to(Sink.ignore())
        .run()(localMat)
}

同样，您可以返回 ActorMaterializer 而不是物化流，并根据时间以外的某些外部条件关闭 ActorMaterializer。