私は Scala と Akka の初心者です。私は単純な RunnableFlow を持っています:
Source -> Flow (do some transformation) -> Sink.runForeach
今、私はこのようなものが欲しいです:
Source -> Flow1 (do some transformation) -> Flow2 (do some transformation) -> Sink.runForeach
ただし、Flow2 は、Flow1 からの 100 個の要素が利用可能になるまで待機し、その後、これらの 100 個の要素を新しい要素 (Flow1 からの 100 個の要素すべてを必要とする) に変換し、この新しい要素をシンクに渡す必要があります。
いくつかの調査を行い、明示的なユーザー定義のバッファーを見つけましたが、flow2 の flow1 から 100 個の要素すべてにアクセスし、それらを使用して何らかの変換を行う方法がわかりません。誰かがそれを説明できますか？または、小さな簡単な例を投稿することをお勧めしますか? または両方？