处理选项里面对于期货

Question

的理解以剧本框架控制器内部下面的代码：

val firstFuture = function1(id) 
val secondFuture = function2(id) 
val resultFuture = for { 
    first <- firstFuture 
    second <- secondFuture(_.get) 
    result <- function3(first, second) 
} yield Ok(s"Processed $id") 
resultFuture.map(result => result).recover { case t => InternalServerError(s"Error organizing files: $t.getMessage")} 

以下是有关功能的一些细节：

• function1回报Future[List]
• function2回报Future[Option[Person]]
• function1 and function2 can run in par等位基因，但function3需要两者的结果。

鉴于这一信息，我有一些问题：

• 虽然应用程序是这样的，这个代码是不太可能有不正确的ID叫，我想处理这种可能性。基本上，我想返回NotFound如果function2返回None，但我无法弄清楚如何做到这一点。
• recover呼叫是否会处理Exception的任何一个步骤？
• 有没有更优雅或习惯的方式来编写这段代码？

Answer 1

我会用Scalaz OptionT去。也许当你只有一个功能未来[Optipn [T]这是矫枉过正，但是当你将开始增加更多的功能，它会成为超级有用的即时

import scala.concurrent.ExecutionContext.Implicits.global 
    import scalaz.OptionT 
    import scalaz.OptionT._ 
    import scalaz.std.scalaFuture._ 

    // Wrap 'some' result into OptionT 
    private def someOptionT[T](t: Future[T]): OptionT[Future, T] = 
    optionT[Future](t.map(Some.apply)) 

    val firstFuture = function1(id) 
    val secondFuture = function2(id) 

    val action = for { 
    list <- someOptionT(firstFuture) 
    person <- optionT(secondFuture) 
    result = function3(list, person) 
    } yield result 

    action.run.map { 
    case None => NotFound 
    case Some(result) => Ok(s"Processed $id") 
    } recover { 
    case NonFatal(err) => InternalServerError(s"Error organizing files: ${err.getMessage}") 
    } 

Answer 2

也许使用collect，然后你就可以recover的NoSuchElementException，可呈现没错，将从中的任何一步恢复失败。 resultFuture将与映射的Result一起获得成功，或者在抛出第一个异常时失败。

val firstFuture = function1(id) 
val secondFuture = function2(id) 
val resultFuture = for { 
    first <- firstFuture 
    second <- secondFuture.collect(case Some(x) => x) 
    result <- function3(first, second) 
} yield Ok(s"Processed $id") 

resultFuture.map(result => result) 
    .recover { case java.util.NoSuchElementException => NotFound } 
    .recover { case t => InternalServerError(s"Error organizing files: $t.getMessage")}