akka-stream

1熱

1答えて

WebSocketサーバーを実装するためにakka httpストリームを使用しています。しかし、クライアントは毎分多くのデータを送信します。したがって、クライアントとサーバーの間で接続が維持されます。ウェブソケットハンドラを実装しているうちに、私はフローとシンクを使用しました。そして、Sink.seqを使用します。シンクは、アップストリームが終了するまで着信エレメントを収集し続けるものです。ど

1熱

2答えて

Akka Streams：GraphDSL APIからMaterialized Sink出力を取得するにはどうすればよいですか？

これは、GraphDSL APIを使用した、本当にシンプルで初心者の質問です。私は、スレッドSO関連するいくつかを読んで、私は答えが表示されない： val actorSystem = ActorSystem("QuickStart") val executor = actorSystem.dispatcher val materializer = ActorMaterializer()(act

0熱

1答えて

SpringとAkkaを使用したリアクティブストリーム

この質問を書く瞬間、私はSpring Framework 5.0.0.M5とAkka 2.4.17を使用しています。プロジェクトでは、現在Akkaの俳優メッセージやストリームを使用しています。 Spring Framework v5にはストリームも含まれています。反応エンジン/ SPI、炉心およびIOモジュールの両方が最終的に春、RxJava、アッカストリーム、Ratpackと組み合わせて、集中ユ

1熱

1答えて

AKKA-HTTPを使用したCSVソースのストリーミング

私はMongodbからreactivemongo-akkastream 0.12.1を使用してデータをストリーミングしようとしています（Akka-httpを使用して）その結果をCSVストリームに返します。 http://doc.akka.io/docs/akka-http/10.0.0/scala/http/routing-dsl/source-streaming-support.html#sim

1熱

1答えて

に定義されているシンクには何も来ません。

も私のために働いていないようです。アイテムは、そこに定義されたシンクにならない。ここに私が持っているものがあります。 val merged: Source[ArticleWithKeywords, _] = ... val (ks, fut) = merged .alsoTo(Flow[ArticleWithKeywords].map { a => a.id -> a.ids.toLi

0熱

1答えて

冷たい観察可能なものを放送するには：バックプレッシャーをかけて再生しますか？

私は実際にScalaを使用していますが、質問はすべてのRxとストリーミングフレームワークに共通です。私は、生成された観測可能な（ひどく寒い）ケースがあり、複数の消費者が正確に同じ値を消費するようにしたいと考えています。私が必要とするのは、リプレイで観測可能なものを放送することですが、最大のバッファサイズを持つリプレイの共通ポリシーは、バッファからオーバーフロー時の要素を削除することです（遅い消

0熱

1答えて

カフカのトピックから利用可能なすべてのメッセージが消費された後に、どのように将来のメッセージリストを返すのですか？

私はおそらくカフカ消費者のポイントを逃したが、私がやりたいことはあるのです：消費者は、トピックにサブスクライブするトピック内のすべてのメッセージをつかみ、それらのメッセージのすべてのリストを将来を返します私が試してみて、これを達成するために書かれているコードは、それが必要なメッセージを消費した後、繰り返しトピックをポーリングし続け、将来はしかし決して戻らない val sink = Sink.

2熱

2答えて

Akkaストリーム：ヘッダ付きのCSV処理

Reading a CSV files using Akka Streams - この質問に基づいています。私は、Akka Streamsを使用してCSVを読み込んでいます。これを行単位で処理する必要がありますが、ヘッダーの名前がわかっている必要があります。オプションはありますか？ UPD。ビットを明確にする。この場合には、ヘッダーを - - FileIO.fromPath(Paths.g

1熱

2答えて

ActorPublisherに基づいてカスタムAkka Streamsソースを実装する

Akka StreamにカスタムSource[ByteSting]を実装したいと思います。このソースは、指定されたファイルから、指定されたバイト範囲内のデータを読み込み、それをダウンストリームに伝播するだけです。私は、これは、ActorPublisherにミックスしたActorを実装することで実現できると思いました。 import java.nio.ByteBuffer import java

2熱

1答えて

Akka Streamsの副作用を使用してwebsocketから受け取ったコマンドを実装する

ウェブサイトのボタンをクリックしてコマンドを表し、websocket経由でプログラムにそのコマンドを発行し、プログラムを処理させたいコマンド（副作用を生成する）を作成し、そのコマンドの結果をレンダリングするWebサイトに返します。 websocketは、ユーザービュー内の異なるアクタによって適用される状態の変更を更新する責任があります。例：ウェブサイトからAI命令を変更しています。これによってい