(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]
上面的代码可以正常工作，并且如果输入不正确或缺少输入，则它们中的任何一个都无法获取信息时，它将返回Nil。我想用更具体的错误消息而不是空列表进行响应。例如，如果找不到HTTP请求中的参数。我想告诉发送者，HTTP参数丢失或找不到给定的订单ID。使用EitherT或Either会有所帮助吗？我该怎么办？谢谢
更新1
我使用ScalazEitherT和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
有关此解决方案或更详尽的解决方案的适用形式（如果需要），请参阅此处
我建议您抛弃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
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句