問題タブ [akka-http]

この質問で説明されているテクニックに基づいて、akka-http. 関連するscalaコードは次のとおりです。

クライアントは単一の http 要求を作成し、単一の応答のエンティティは ByteString のチャンク ストリーム、つまり 1 秒ごとの「テスト」です。

scala クライアントを使用して、ストリームが「テスト」値を生成することを確認しました。ただし、非常に便利なデバッグ方法は、Web ブラウザーをマイクロサービスに向けて、データが入ってくるときにチャンク ストリームを表示することです。Chrome ブラウザーをポートに向けようとしましたが、ブラウザーは読み込み/ビジー状態でハングしました。

私の質問は、ブラウザがストリームをリアルタイムで表示できるように HttpResponse を変更するにはどうすればよいですか?

ソフトウェア クライアントの消費用とは異なるブラウザー表示用の HttpResponse エンティティを必要とするソリューションは問題ありません (たとえば、"/stream" アドレスがクライアントに HttpResponse を提供し、"/browserView" が別の HttpResponse を提供する場合、これは受け入れられる回答です)。

akka http で 60 以上の API を使用して REST Web サービスを作成する場合。akka ストリームと akka アクターのどちらを使用するかを選択するにはどうすればよいですか? Jos は彼の投稿で、akka http で API を作成する 2 つの方法を示していますが、いつどちらを選択すべきかについては示していません。

すでに質問されていることは知っていますが、答えが見つからないようです。これが私のコードです:

このコードはエラーを生成します

この種のエラーの最も一般的な原因は、マーシャリングの暗黙的roadsな定義をスコープにインポートするのを忘れていることですが、私はこれを忘れていませんでした。もう 1 つの理由は、FlowMaterializerの代わりにスコープ内に暗黙的を指定している可能性がありますActorMaterializerが、ImplictMaterializer特性がこれを処理します。

私が行方不明になる可能性のあるものは他にありますか？

Scala 2.11.7、Akka 2.3.11、akka-http 1.0、spray-json 1.3.2 を使用しています。

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

私が考えられる唯一のことは、httpResponse フローで 400 エラーをキャッチし、デフォルト値を返すことです。しかし、事前に失敗することがわかっているリクエストに対してサーバーにアクセスするオーバーヘッドを回避できるようにしたいと考えています。