akka-stream

2熱

1答えて

UnmarshallerをHttpRequest-> HttpResponseフローに適用するにはどうすればいいですか

HTTPサービスを扱うために私のJavaプロジェクトでakkaフレームワークを使用するので、akkaストリームを扱うためにjavaDSLを使用しています。それで、以下の私の話。私は（私の俳優で）HTTPキャッシュされたプールの作成：その後、私はHttpRequestのに基づいてソースを作成 val pool = Http.get(getContext().system()).cachedHost

1熱

1答えて

どのように私はこれをプレイ2.4で2.5

を再生するために2.4 JSONストリームの例を再生する翻訳することができ、私は書くことができます： import play.api.libs.json._ import play.extras.iteratees._ val jsonStream: Enumerator[JsObject] = enumerator &> Encoding.decode() &>

6熱

1答えて

StreamでのAkka-http-clientリクエストのチェーン

ストリームとしてakka-http-clientを使用してHTTPリクエストをチェーンしたいとします。チェーン内の各HTTP要求は、以前の要求の成功/応答に依存し、新しい要求を構築するためにそれを使用します。リクエストが成功しなかった場合、Streamは失敗したリクエストのレスポンスを返します。どのようにakka-httpでこのようなストリームを構築できますか？ akka-httpクライアントレ

0熱

1答えて

Akka Stream postStopのノードの結果ステータスを照会

Akka Stream GraphStageLogicのpostStopでは、ステージがエラーなしで失敗したか完了したかを判断する方法はありますか？例えば。が得られます。failStageが呼び出された場合はFailure、completeStageの場合はSuccessとなります。 failStageはfinal方法であり、それは documentationも有用何も言っていないにフックする方

0熱

1答えて

PlayからAkkaへのWebSocketの移動HTTP

PlayアプリケーションにWebSocketサーバーがあり、これをakka-httpサービスに移動したいとします。私は現在、Acckaには存在しないPlayの一部であるActorFlow.actorRefを使用しています。 WebSocketが承認されると、私はRabbitMQキューに登録し、各メッセージをWebSocketに転送します。 WebSocketからメッセージを受け取ると、ローカルで処

1熱

2答えて

FileIO.fromPathからBytestringを慣用的に取得する方法

スカラのFileIO.fromPathからakka Bytestringを取得する方法は何ですか？

2熱

1答えて

シンクとシンクが

目標が返さソースがシンクが受信するどの発するこの署名 def bindedSinkAndSource[A]:(Sink[A, Any], Source[A, Any]) = ??? で機能を実現することである受信どんな放射するソースを作成アッカストリーム機能。私の主な目標は、handleWebSocketMessagesディレクティブによってWebSocketのフォワーダを実装することです。

5熱

1答えて

未来[T]を放つソースを扱うには？

のは、私はいくつかのイテレータを持っているとしましょう： val nextElemIter: Iterator[Future[Int]] = Iterator.continually(...) そして、私はそのイテレータからソースを構築したい： val source: Source[Future[Int], NotUsed] = Source.fromIterator(() => n