scala - 如何创建一个在标志降低之前暂停的 Akka Stream Flow？

Question

我想创建一个 Akka Streams Flow，它将消耗一个元素并保持它直到一个 Flag 被降低。

所需的效果如下所示，但我意识到这不是一个好的解决方案。

val flow: Flow[Int, Int, NotUsed] = {
     Flow[Int] map { i =>
       if (flagIsRaised) { waitUntilFlagIsLowered(); i}
       else { i }
     }
}

例如，我不想要 waitUntilFlagIsLowered阻止。

理想情况下，我想要一个惯用的 Akka Streams 解决方案，使用 standard Akka Streams operators 可能是可能的。 .

Answer 1

查看 Valve 实用程序来自 Akka Streams Contrib项目:

Materializes into a Future of ValveSwitch which provides a the method flip that stops or restarts the flow of elements passing through the stage. As long as the valve is closed it will backpressure.

如何使用它的示例在 ValveSpec .