关闭资源清理的Akka流

Question

当使用Akka Streams时，有什么方法可以关闭/关闭不再需要资源清理的流吗？

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

用法示例：

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

有没有一种方法来关闭流？

Answer 1

您可以运行在一个独立的ActorMaterializer的Stream和一段时间后调用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一些外部条件，而不是时间。