future

    -2

    2答えて

    メソッドから結果を返そうとしているときにScalaに問題があります。 私はPlay 2.6とReactiveMongoを使用しています。画像内 エラーが怒鳴る: 誰かがいくつかの手がかりを与えてもらえますか?上記のコードのよう result.map(writeResult: WriteResult => { case Success => entity case Failure

    1

    1答えて

    アッカ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

    3

    4答えて

    私はいくつかのコードを継承しましたし、元の開発者が左の誰もありません。コードは大きくCompletableFutureを使用しています。初めて使用するので、まだ私の頭の中を包み込んでいます。私が理解しているように、通常はが、時間のかかる作業が実行されている間に何か他のことを行うことを可能にするマルチスレッド化メカニズムとともに使用され、その後単にFutureを介してその結果をフェッチします。しかし

    0

    1答えて

    HTTP GET要求をいくつか同時に送信し、すべての応答がタイムアウトするまで待機する関数を作成しているとします。少なくとも1つの応答がステータス200を持たないか、タイムアウトにならない場合、私の関数は失敗を返します。 私はこのように、この機能tryGetsを書いています: import java.net.URL import scala.concurrent.duration._ imp

    0

    1答えて

    大きなシステムで処理されるファイルの進行状況を監視して維持するユーティリティを構築しています。このファイルは、大きな「テキスト」ファイル、.csv、.xls、.txtなどです。これは、カフカからのデータのストリーミング、Avroへの書き込み、またはSQL DBのバルクバッチでの書き込みです。私は処理された行の数を記録し、RESTful API呼び出しを使用してDBに進捗を持続させる "catcha

    0

    1答えて

    私は、プレイフレームワークを使用してレストアピを書こうとしているスカラ初心者です。私は次の3つのデータアクセス方法を持っています getDataDict: (dsType:String, name:String) => Future[Option[DatasetDictionary]] getDatasetData: (DatasetDictionary) => Future[List[Data

    0

    1答えて

    私はPlay 2.6とScalaにアプリを持っていますが、Futureを返すようにすべてのActionを設定したい、あるいは設定ファイルによってActionまたはAction.asyncと言うことができます。だから私は、プロダクションやテスト環境で動作するように私のアプリ全体を構成することができます。 私はそれを行う方法を知りません。 Hpw私はそれを勉強して実装することができますか? ありがとう

    1

    2答えて

    私はこのような機能を持っていると仮定します。 import scala.concurrent._ def plus2Future(fut: Future[Int]) (implicit ec: ExecutionContext): Future[Int] = fut.map(_ + 2) は今、私は新しいFutureを作成するplus2Futureを使用しています: imp

    0

    4答えて

    私はClojureでいくつかの未来を創り出し、それらをすべて特定のスレッドで実行して、それらが1つずつ実行されるようにしたいと思います。これは可能ですか? これを行うためにJavaライブラリをラップするのは難しくありませんが、それを行う前に、私はClojureのやり方を忘れていないことを確認したいと思います。 Javaでは、私はFutureTaskを実装し、それらのタスクをシングルスレッドエグゼキ