在Akka Streams處理acks

Question

我已經看到了使用Akka Streams來避免背壓的例子，但是想知道如果我需要自定義acks下游，這是如何工作的？

以我特定情況下，我有幾個flows在該方法中的消息，並且當它達到一定flow我想傳遞一個ack回到源以信號通知我現在已經「採取所有權」的鏈資源是流程。

這個工作在Akka Streams中是如何工作的？

Answer 1

我想這個問題有多種解決方案。一個簡單的方法是通過Promise[Unit]來增加數據，以便成功完成以發信號確認。 這有其缺點（即缺乏背壓支持），但它有簡單的一面。

有關該主題的更多信息，請查看this blogpost。

Acked-stream是基於這種方法的優秀圖書館。