akka-http

1熱

1答えて

私はhost-level API with a queueを使用しています。 private val (queueSource, connectionPool) = Source.queue[(HttpRequest, Promise[HttpResponse])](queueSize, OverflowStrategy.backpressure).async .viaMat(poolF

0熱

1答えて

クライアントアプリケーション用のakka-streamsとakka-httpを使用した認証の処理方法

認証済みWebサービス（認証トークンを返す）に接続する必要があるAkka StreamsとAkka Httpを使用してアプリケーションを作成しています定期的にサービスを照会し、クエリに応じて他のアクションを実行する可能性があります（ファイルのダウンロードなど）。認証トークンは一定の時間が経過するとタイムアウトするため、リフレッシュする必要があります。認証トークンはどのように処理すればよいですか？

1熱

1答えて

スカラアッカのHttp - 利用ルート返される未来[A] JSON

アッカHTTPバージョンとして "アッカ-HTTP" "com.typesafe.akka" %%％ "10.0.11" ストリームバージョン： " com.typesafe.akka」%% "アッカ・ストリーム" ％ "2.5.7" プレイJSON版： "com.typesafe.play" %% "PLAY-JSONを" ％ "2.6.7" I持ってcrudServiceで、次の方法： def

2熱

1答えて

Akka http-clientはサーバーからのすべてのデータストリームを消費することはできません

このストリームを消費するためのシンプルなakkaストリーム休止エンドポイントとクライアントを作成しようとしています。しかし、私はサーバーとクライアントを実行しようとすると、クライアントはストリームの一部だけを消費することができます。私は実行中に例外を見ることができません。ここでは私のサーバーとクライアントです： import akka.NotUsed import akka.actor.Act

0熱

2答えて

Akka-http：localhostのwebsocketに接続

私はlocalhostのwebsocketを通していくつかのサーバに接続しようとしています。 ws = new WebSocket('ws://localhost:8137'); でJSでやろうとすると成功します。しかし、akka-httpとakka-streamsを使用すると、「接続に失敗しました」というエラーが表示されます。 object Transmitter { implic

0熱

1答えて

GenericHttpCredentialsを使用してHTTP要求ヘッダーからトークンを抽出します

私のHTTP要求の承認ヘッダーからトークンを抽出しようとしています。権限ヘッダの形式はAuthorization: Token token=abcdefg123です。私は次の関数シグニチャを持っていますが、次のコードスニペットを試したとき、コンパイルエラーはCannot resolve symbol Map. Cannot resolve method Map.unapplyです。なぜこれが起こっ

1熱

1答えて

Slickストリーミングデータの変換とAkka Httpを使用したチャンクレスポンスの送信

目的は、データベースからデータをストリーミングし、このデータチャンクで何らかの計算を実行することです（この計算は、あるケースクラスの未来を返します）ユーザに提供する。現在、私はデータをストリーミングし、計算を実行せずに応答を送信できます。しかし、私はこの計算を実行できず、結果をストリーミングすることができません。これは私が実装したルートです。 def streamingDB1 = path("

0熱

1答えて

Mac OSのdockerでRESTアプリケーションを実行しているときに空の応答

SBTを使用して簡単なスカラアプリケーション（akka-http RESTサービス）を作成しました。これは、アプリケーションのメインクラスです： object UserApiWebService extends App { override def main(args: Array[String]): Unit = { implicit val system: Actor