問題タブ [alpakka]

Alpakka-FTPを使用していますが、一般的な akka-stream パターンを探しているのかもしれません。FTP コネクタは、ファイルを一覧表示したり、それらを取得したりできます。

理想的には、次のようなストリームを作成したいと思います。

しかし、上で書いた 2 つの関数でそのようなストリームを作成することはできません。Flowのようなものを使用してそこに到達できるはずだと感じています

ls上記の関数と関数のみが与えられた場合、これは可能fromPathですか?

編集：

1 つのアクターと を使用して解決することはできますがmapAsync、それでももっと簡単にする必要があると感じています。

読み取り用に既存の交換内にキューを作成したいと考えています。

別のアプリケーションがこの交換にメッセージを発行し、それらをすべてのメンバー キューに展開しています。新しいアプリケーションをこれらのメッセージのサブスクライバーに追加したいと考えています。

以下は、キューを作成します。

そして、これは交換のためのシンクを作成します

しかし、それが正しいアプローチである場合、それらを一緒に使用する方法がわかりません。