Scalaz：如何链未来[列表[A]，选项[A]和未来[选项[A]和报告出错个别

问题描述：

(for { 
    orderId <- ListT(extractParamFromHttp(request).toList) // extractParamFromHttp(request) returns Option[Long] 
    order <- ListT(serviceA.retrieve(orderId).map(_.toList)) // serviceA.retrieve(...) returns Future[Option[Order]] 
    items <- ListT(serviceB.retrieve(order.id).map(_.toList)) // serviceB.retrieve(...) returns Future[Seq[OrderItem]] 
    } yield items).map(...) // convert items to JSON and return as Future[Result]

上述工程的代码，当其中任何一个失败，它返回一个零如果给出错误的输入或缺少输入，请获取信息。我想要更具体的错误消息，而不是空的列表响应。例如，如果HTTP请求中的参数未找到。我想告诉发件人HTTP参数丢失或找不到给定的订单ID。会使用EitherT或Either有帮助吗？我应该怎么做呢？感谢Scalaz：如何链未来[列表[A]，选项[A]和未来[选项[A]和报告出错个别

更新1

我解决它使用Scalaz EitherT和Either（提示从Validation），并有轻微的变化粘贴在这里我的解决方案，

import scalaz._ 
import Scalaz._ 
import scala.concurrent.Future 
import scala.concurrent.ExecutionContext.Implicits.global 

case class Order(id: Long, desc: String) 
case class Vendor(id: Long, name: String) 

def extractHeader(valid: Boolean): Option[String] = if (valid) Some("bob") else None 
def retrieveVendor(username: String, found: Boolean): Future[Option[Vendor]] = 
    if (found) Future.successful(Some(Vendor(103, "Bob Enterprise"))) else Future.successful(None) 
def retrieveOrders(vendorId: Long, found: Boolean): Future[List[Order]] = 
    if (found) Future.successful(List(Order(1, "Product 1"), Order(2, "Product 2"))) else Future.successful(List.empty[Order]) 

def output(result: Future[\/[String, AnyRef]]) = result.foreach { 
    case -\/(s) => println(s"Error: $s") 
    case \/-(ys @ x :: xs) => println(ys) 
    case \/-(s) => println(s) 
} 

def orders(valid: Boolean, userFound: Boolean, vendorFound: Boolean) = for { 
    username <- EitherT(Future.successful(extractHeader(valid) \/> "Bad headers")) // Option[String] 
    vendor <- EitherT(retrieveVendor(username, userFound).map(_ \/> "Bad username")) // Future[Option[Vendor]] 
    orders <- EitherT(retrieveOrders(vendor.id, vendorFound).map {     // Future[Seq[Order]]  
    case Nil => "Bad vendor".left 
    case xs => xs.right 
    })                    
} yield orders 

output(orders(false,false, true).run)

参考答案非Scalaz解决方案

更新2

对于应用形式（如果需要）到该解决方案或更精心的解决方案，请参阅here

看scalaz.Validation –

答

我建议你折腾scalaz，它带来任何价值，这种使用情况下，只是让事情对你更加混乱。不保持简单的事情通常是这样的问题的原因。

def ifExists[T, R](opt: Option[T], err: String)(f: T => Future[R]) = 
    opt.fold(Future.failed(new IllegalArgumentException(err))(f) 

for(
    order <- ifExists(extractParamFromHttp(request), "Missing param) { 
    serviceA.retrieve(_) 
    } 
    items <- ifExists(order, "Order not found") { serviceB.retrieve(_) } 
    result <- ... 
) yield result

这返回Future[Result]，即，完成时将包含任一的最终结果或指示失败原因的异常。然后主叫方可以与future.handle...检查异常或处理成功和失败与future.transform或future.onComplete

我不同意，我不应该问题复杂化的任何比他们更需要。对于这种情况，我发现scalaz解决方案是简洁的，这些是我认为可以很好地利用它们的少数几个领域。我可能稍后改变:) – thlim

“简洁”？它实际上比我更长......并且不处理所有情况_（因此，你的问题在这里）...... – Dima

Scalaz：如何链未来[列表[A]，选项[A]和未来[选项[A]和报告出错个别

相关推荐