我有一组按顺序完成的操作,但如果中间序列返回“null”,我想提前中止操作(跳过后续步骤)。
我想出了一个这样的函数,它给出了一个输入参数,对Redis执行几个操作,并返回一个产品(如果存在)。由于其中一个中间请求可能返回空值,因此完整操作可能会“失败”,并且我希望将之后发生的不必要步骤短路。
这里的筑巢变得疯狂,我想让它更清晰。是否有适当的“功能”方式来执行这种类型的"if/else"
短路?
def getSingleProduct(firstSku: String): Option[Product] = {
val jedis = pool.getResource
val sid: Array[Byte] = jedis.get(Keys.sidForSku(firstSku, sectionId, feedId).getBytes)
Option(sid).flatMap {
sid: Array[Byte] =>
Option(jedis.get(Keys.latestVersionForSid(sectionId, feedId, sid))) flatMap {
version: Array[Byte] =>
Option(Keys.dataForSid(sectionId, feedId, version, sid)) flatMap {
getDataKey: Array[Byte] =>
Option(jedis.get(getDataKey)) flatMap {
packedData: Array[Byte] =>
val data = doSomeStuffWith(packedData)
Option(Product(data, "more interesting things"))
}
}
}
}
}
这样做的方法是使用for
:
for {
sid <- Option(jedis.get(...))
version <- Option(jedis.get(..., sid, ...))
getDataKey <- Option(jedis.get(...version,...))
packedData <- Option(jedis.get(getDataKey))
} yield {
// Do stuff with packedData
}
如果任何None
调用返回get
,这将返回None
,否则它将返回Some(x)
,其中x
是yeild
表达式的结果。
您可能还想考虑为jedis.get
编写一个包装器,它返回Option(x)
而不是使用null
作为错误结果。