akka-stream

9熱

2答えて

私はakkaストリームを使用しています。フローが特定の値を処理できないため、条件付きでスキップする必要があるグラフのセグメントがあります。具体的には、文字列を受け取りHTTPリクエストを行うフローがありますが、文字列が空の場合、サーバーはそのケースを処理できません。しかし、代わりに空の文字列を返す必要があります。失敗することを知ってhttpリクエストを通過することなくこれを行う方法はありますか？私

6熱

2答えて

Akka-HTTP：ファイルアップロード

私はakka httpを使って簡単なファイルアップロードを実装しようとしています。次のように私の試みはなります import akka.actor.ActorSystem import akka.event.{LoggingAdapter, Logging} import akka.http.scaladsl.Http import akka.http.scalad

6熱

1答えて

Akka StreamsとHTTPを使用してHTTPリソースをファイルにダウンロードする方法は？

ここ数日、Akka StreamsとHTTPを使用してHTTPリソースをファイルにダウンロードする最良の方法を見つけようとしています。は当初、私はFuture-Based Variantで開始し、それがこのようなものに見えた： def downloadViaFutures(uri: Uri, file: File): Future[Long] = { val request = Get

5熱

3答えて

akka-httpチャンクレス応答連結

私はakka-httpを使用して、チャンク応答を返すhttpサービスにリクエストします。この場合にはJSON終了 - ----- {"data": ----- "some text"} ----- {"data": ----- "this is a longer ----- text"} ----- {"data": "txt"} ----- ... データの論

14熱

1答えて

マップとmapAsyncの違い

誰でも地図とmapAsync w.r.t AKKAストリームの違いを教えていただけますか？ In the documentation 外部の非ストリームベースのサービスを含むストリームの変換や副作用がmapAsyncを行うことができるかmapAsyncUnordered なぜカント我々は単に私たちがここにマッピングすると言われて？フロー、ソース、シンクはすべて本質的にモナドであると仮定し、マップ

7熱

2答えて

アッカHTTPストリーミングJSONデシリアライズ

は、それが動的にがドメインオブジェクトにアッカのHTTPから、未知の長さで、ByteStringストリームを外部をデシリアライズすることは可能ですか？コンテキスト私は成長し続けてJSON Arrayを出力無限長いHTTPエンドポイントを呼び出します。 [ { "prop": true, "prop2": false, "prop3": 97, "prop4": "sample" },

6熱

2答えて

サーバからのakka-http websocket接続を閉じる

私のシナリオでは、クライアントは「さようなら」websocketメッセージを送信し、以前に確立した接続をサーバ側で閉じる必要があります。アッカ-HTTP docsから：閉会の接続は、（Sink.cancelledとSource.emptyにその上流にその下流に接続することにより）、サーバー・ロジックからの着信接続の流れをキャンセルすることにより可能です。また、IncomingConnectio

5熱

2答えて

AkkaストリームのソースとしてSpark DStreamを使用する慣用句

Sparkクラスタで計算を開始し、結果のチャンクストリームで応答するREST APIを構築しています。 Sparkストリームに計算結果がある場合、Sparkからデータを送信するには、 dstream.foreachRDD() を使用できます。私は、アッカ-HTTPでチャンクHTTP応答を送信しています：簡単にするために val requestHandler: HttpRequest => Ht

5熱

1答えて

Akkaストリームはどのようにして継続的にマテリアライズできますか？

私はAWS Java SDKを使用してAWS SQSキューからポーリングするためにScalaでAkka Streamsを使用しています。私も2秒間隔でフローを実行しようとしています私のアプリケーションで class SQSSubscriber(name: String) extends ActorPublisher[Message] { implicit val materializer