問題タブ [akka-http]

この例を実行することで、Akka HTTP の経験を積んでいます。学習のために、Maven プロジェクトに変換しました。ただし、Akka v2.3.12 と Akka Stream v1.0 を使用すると、次のようなコンパイル エラーが発生します。POST DSL は、簡潔にするために投稿していない同様のエラーで失敗します。サンプルを実行するにはどうすればよいですか?

akka-http に問題があります。フローで複数回リクエストしようとしていますが、デフォルト設定で 4 回で停止します。これが私が使用するコードです。誰かがそれがなぜ待つのか理解するのを手伝ってもらえますか?

どうもありがとう

私は akk-http で残りのテスト ケースを書いています。ステートメントでこのエラーが発生しています。私のwhen(mockedRepository.getAllFromModule).thenReturn(x)クラスは次のとおりです。

これは、postgres データベースからすべてのモジュールのリストImplModuleRepositoryを返す抽象クラスです。プログラムは上記のようにエラーを表示しています。実際にはステートメント theReturn(x) はコンパイルされておらず、コンパイル時にこのエラーが表示されています。

何が悪いのかわかりません。

akka-stream-and-http-experimental1.0で遊んでいます。これまでのところ、HTTP 要求を受け入れて応答できるユーザー サービスができました。また、アポイントメントを管理できるアポイントメントサービスも予定しています。予約するには、既存のユーザーである必要があります。予約サービスは、ユーザーが存在するかどうかをユーザー サービスに確認します。これは明らかに HTTP 経由で実行できますが、予約サービスがユーザー サービスにメッセージを送信するようにしたいと考えています。akka-httpこれに慣れていないので、メッセージを送受信するためにアクターを (抽象化として) 使用する方法が明確ではありません。ドキュメントにはActorRefandについての言及がありますが、前者と後者の例はありません。私のコードは次のようになり、Githubにあります。ActorPublisher

編集：メッセージを送信する方法を見つけました。これは、を使用して実行できますSource.actorRef。これは、メッセージをストリームに送信するだけです。私がやりたいのは、ルート ハンドラー クラスが応答を受け取ることです。そうすれば、予約サービスを作成するときに、そのアクターはユーザー サービス アクターを呼び出して、例のユーザー ルート ハンドラーと同じ方法で応答を受け取ることができます。擬似コード:

val src = Source.single(name) \\ How to send this to an actor and get the response

編集2：@yardenaの回答に基づいて、次のことを思いつきましたが、最後の行はコンパイルされません。私のアクター パブリッシャーは、でラップされ、 としてルート ハンドラーに配信されるとFuture推測している を返します。PromiseFuture