問題タブ [akka-stream]

Reactivemongo を使用して、mongodb から列挙子を取得できます。

akka-http と akka-stream を使用して、この列挙子からストリーミングする方法は?

プレイストリーム実験ライブラリを使用して、列挙子をパブリッシャーに変換しました。

akka-http のように、

しかし、ストリームは終了せず、クライアントはまだデータを待っています。列挙子の作成中に問題はありますか?. または、 Enumerator を publisher に変換する際の問題ですか?

私はすでにreactivemongo googleユーザーグループとplayユーザーグループに質問を投稿しました https://groups.google.com/forum/#!topic/reactivemongo/uObGXFQFH0Y

ソースとして 2 つのアクター、マージ ジャンクション、1 つのシンクを使用して、(Java DSL で) akka ストリーム フローを構築して実行しようとしています。

私の質問は、ソース アクターにメッセージを送信するために、ソース アクターへの ActorRef 参照を取得するにはどうすればよいですか? アクターが 1 人の場合、グラフ ビルダーは使用せず、.run() または runWith() メソッドは ActorRef オブジェクトを返します。しかし、多くのソース アクターの場合はどうすればよいでしょうか。そのような流れを実現することは可能なのでしょうか?

内部にグラフを作成してカスタム シンクを作成しています。これは、私の質問を示すために私のコードを大幅に簡略化したものです。

私が抱えている問題は、次のような単一の型引数と値引数なしで同じ入力/出力型の Flow を作成することは有効ですが、Flow[Int](これはドキュメント全体にあります) 2 つだけを指定することは有効ではありません。型パラメーターとゼロ値パラメーター。

Flow オブジェクトのリファレンス ドキュメントによると、apply探しているメソッドは次のように定義されています。

と言う

指定された create 関数に FlowGraph.Builder を渡すことで Flow を作成します。

create 関数は、作成された Flow の入力ポートと出力ポートに対応する Inlet と Outlet のペアを返すことが期待されます。

非常に単純なフローだと思うものを作成しようとすると、別のレベルのグラフビルダーに対処する必要があるようです。内部ポートをいじる必要のない入力と出力のタイプを変更する Flow を作成する、より簡単で簡潔な方法はありますか? これがこの問題にアプローチする正しい方法である場合、解決策はどのようになりますか?

ボーナス: 入力の型を出力から変更しないフローを簡単に作成できるのはなぜですか?

フォルダー内の新しいファイルの処理を処理する Akka の javadsl でストリームをセットアップしようとしています。私の質問は：

新しいファイルが導入されるたびに RunnableFlow を再実行する必要がありますか?

または、ストリームが新しいファイルがそのフローのソースに導入されるのを待っている間、RunnableFlow を無期限に実行し続けることは可能ですか?

現在の私の情報源：

Queue は単純な反復可能なキューです

受信している着信文字列を複数の文字列に分割する解決策を考え出そうとしています。私が調査したところ、以前のバージョンの Akka-Streams には、Transformerこの種の変換を行うために拡張できるクラスがあったようです。

私が使用しているバージョン (RC2) にはStages がありますが、分割パターンを実装する方法がよくわかりません。

XXXXXa を入力しStringてシーケンスを返し、Stringそれぞれをフローの残りの部分に出力できるコンポーネントを探しています。

私は akka-io ack で動作するように設計された Actor を持っており、アップストリーム (ネットワーク) にメッセージを送信するときに ack を待ちます。このアクターは、バックエンドの非同期アプリケーションへのインターフェイスです。

この Actor を akka-streams に変換できるラッパー レイヤーが必要です。これにより、Flow[Incoming, Outgoing, ???]そのような署名を期待する新しいライブラリと統合できます。

(アップストリームからの着信メッセージはめったにないので、バックプレッシャについてはあまり気にしませんが、それは悪いことではありません。)

私は、akka-user メーリング リストから、アクターをストリームと統合するコードが akka-streams にないことを正当に認めています。 プッシュプルステージ.

ここでは、実際には 2 つPushPullStageの が必要なようです... 1 つは for でupstream => SimpleActor、もう 1 つは ですSimpleActor => upstream。

私の質問は次のとおりです。

1. このようなアクターとストリーム間の統合を提供するライブラリはありますか?
2. PushPullStageゼロから双方向を実装するよりも簡単な方法はありますか?
3. そのような実装のストレス テストを可能にする既存のテスト フレームワークはありますか?