Akkaストリームのacksの処理

Question

Backpressureを回避するためにAkka Streamsを使用する例を見てきましたが、カスタムをacks下流に流す必要がある場合、この方法が不思議ですか？私の特定の場合において

私はメッセージを処理し、それが一定のflowに達したときに、私は今の「所有権を取られ」たことを通知するために、元に戻すackを渡したい鎖でflowsいくつかリソースは処理中です。

Akka Streamsではどのように動作しますか？

Answer 1

この問題の解決策が複数あるとします。簡単な方法は、Promise[Unit]を使用してデータを補完して、ackを知らせることです。 これは短所（すなわち、背圧のサポートの欠如）がありますが、その面では単純さがあります。

トピックの詳細については、this blogpostを参照してください。

Acked-streamは、このアプローチに基づいた優れたライブラリです。