future

-2熱

2答えて

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

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

3熱

4答えて

マルチスレッドを使用せずにFutureを使用するポイントは何ですか？

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

0熱

1答えて

同時HTTP GET要求を送信する先

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

0熱

1答えて

将来呼び出されるwhileループは、毎回呼び出されません

大きなシステムで処理されるファイルの進行状況を監視して維持するユーティリティを構築しています。このファイルは、大きな「テキスト」ファイル、.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を設定する方法

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

1熱

2答えて

Scala Futureのマップはオーバーヘッドを追加しますか？

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

0熱

4答えて

Clojure先物を1つのスレッドで実行する方法は？

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