스칼라에서 미래의 가치 실현하기

Question

데이터베이스에서 레코드를 읽는 데 사용하는 다음 코드 스 니펫이 있는데 ReactiveMongo를 사용하고 있습니다.

val futureList: Future[Option[BSONDocument]] = collection.find(query).cursor[BSONDocument].headOption 

val os: Future[Option[Exam]] = futureList.map { 
    (list: Option[BSONDocument]) => list match { 
    case Some(examBSON) => { 
     val id = examBSON.getAs[Int]("id").get 
     val text = examBSON.getAs[String]("text").get 
     val description = examBSON.getAs[String]("description").get 
     val totalQuestions = examBSON.getAs[Int]("totalQuestions").get 
     val passingScore = examBSON.getAs[Int]("passingScore").get 
     Some(Exam(id, text, description, totalQuestions, passingScore)) 
    } 
    case None => None 
    } 
}.recover { 
    case t: Throwable => // Log exception 
    None 
} 

미래를 반환하기 위해 메소드 서명을 변경하고 싶지 않습니다. 나는 미래의 가치를 얻고 그것을 호출자에게 돌려주고 싶다.

import scala.concurrent.duration._ 

val os: Future[Option[Exam]] = ??? 
val result = Await.result(os, 10 seconds) 
result.getOrElse(/* some default */) 

주

미래가 완료되거나 제한 시간이 만료 예외가 슬로우 될 때까지 스레드를 차단합니다 차단, 노트이 좀 패배 있다는 것을 :

Answer 1

당신은 awaitable 객체를 사용하여 차단 한 후 필요 비동기 계산을하기위한 목적이지만 사용 사례에 따라 다를 수 있습니다.

당신이 결과를 필요로하지 않는 경우 결과도 반환 즉시 액세스 할 수없는, 그래서 즉시 미래가 완료되면 onComplete은 해고 될 것이라고 onComplete

os onComplete { 
    case Success(someOption) => myMethod(someOption) 
    case Failure(t) => println("Error) 
} 

주를 사용하여 콜백을 첨부 할 수 있습니다 유형은 Unit입니다.