akka-stream

5熱

1答えて

私はアッカストリームで<code>RunningGraph</code>を作成している場合は、閉じたグラフアッカストリーム

の監視、どのように私は（外部から）を知ることができ、すべてのノードが原因完了までにキャンセルされますか？エラーのためにすべてのノードが停止した場合

2熱

1答えて

Scalaでランタイム型パラメータを持つジェネリックメソッドを呼び出すにはどうすればよいですか？

背景私はAkkaのストリームを使用していると私はOutがSeqときのために特別であるFlow[In, Out, Mat]にいくつかの拡張メソッドを追加したいです。（後でフォローする詳細）次に trait StageOps[+Out, +Mat] { protected val stage: FlowOps[Out, Mat] type Repr[+O] = stage.Re

3熱

1答えて

AkkaHTTP：mutlpartのアップロード（エンティティ（[Multipart.FormData]として）を使用しているときに、キャプチャされた値にアクセスする方法

ファイルをアップロードしているのにキャプチャされた値にアクセスしようとしていますが、。は、ここでのサンプルコードです： trait TestRoute extends { val regEx = """(\w+)""".r def testRoute: Route = path("testing"/regEx/regEx/regEx){ post {

5熱

1答えて

EventStreamからソースを作成する

私はPlayFramework 2.5.3を使用しており、akka.event.EventStreamからakka.stream.scaladsl.Sourceを作成したいと考えています（イベントストリームはアクターシステムの一部です）。イベントストリームは特定のタイプのイベントを生成するので、特定のタイプのイベントに登録してplay.api.mvc.Results.chunkedを使用してプッシ

4熱

2答えて

Akka-Streamsでプロデューサを遅らせる方法

akka-streamsの問題を解決しようとしています。私の最初のプロデューサがキュー/ mongodbコレクションを連続して取得し、設定された間隔内で実行したいと考えています。それを実現するには？

13熱

1答えて

Akka HTTPを使用したファイルアップロード

Akka HTTPを使用してアプリケーションにファイルアップロード機能を実装しようとしています。私はakka-streamバージョン2.4.4を使用しています。ここコード（akka-docから改変） path("fileupload") { post { extractRequestContext { ctx => { implicit val m

0熱

1答えて

アッカは、私が<code>Source</code>に</p> <pre><code>val flow : FlowOps = Source(1 to 10).map(_+1) </code></pre> <p>を解析したいが、簡単な方法がないように見えるソース

にを解析ストリーム。私はこの回避策を実行しました Source.fromGraph( GraphDSL.create() { builder => val flow = Source(1 to 10).map(_+1) SourceShape(builder.add(flow).out) } ) 単純なストリームを再びグラフに変換

5熱

1答えて

Akkaストリーム - 別のディスパッチャにIOバウンドフローを設定する

私のストリームには、CPUバウンドステージとIOバウンドステージが均等に混在しています（IOステージごとにCPUステージが続きます）。私がやりたいことは、IO操作を残りのストリームとは異なるディスパッチャに置くことです。従来のアクターベースのAkkaアプリケーションでは、IOアクターを多数のスレッドで固定スレッドプールディスパッチャーに配置し、CPUバインドアクターを少数のスレッドでフォーク結合

2熱

1答えて

Akka 2.4.6でTCPクライアントを使用してSSLを設定する方法は？

TLSでTCP接続を設定しようとしていますが、それに関する最新のドキュメントが見つかりません。私はfound something about Akka streams 2.2は2.4.x用のものを見つけることができました。は私がthisドキュメントおかげで見てきました！