有没有办法在不改变价值传播的情况下，在未来的链中产生副作用

Question

我有一个未来链，它获取一个资源，使用它来检索一些数据，然后修改该数据并返回结果（仍然在未来）。

我希望在返回未来链之前释放资源，但不必插入更接近的样板代码（即，将中间结果放入某个变量中，然后将其作为链其余部分的结果返回）。

我在找这样的东西：

.getResource() //returns future
   .flatMap(resource => resource.getUsageResult()) //returns future
    .FUNCTION_I_NEED(resource.free()) 
    //executes for failures and successes, doesn't change propagated exceptions or values
   .flatMap(usageResult => mutate(usageResult)) //returns future

Answer 1

您可能正在寻找和然后-运算符：

something.getResource()
.flatMap(resource => resource.getUsageResult() andThen { case _ => resource.free() })
.flatMap(usageResult => mutate(usageResult))

Answer 2

你可以这样做：

getResource()
  .flatMap(resource => {
    resource.getUsageResult()
      .map(result => {
        // .map makes sure the usage result is done
        // do your side effect here
        yourSideEffectOn(resource)
        // return the result again so you can do something with it
        result
      })
  })
  .flatMap(usageResult => mutate(usageResult))

你应该能够通过使用理解来简化它：

for {
  resource <- getResource()
  usageResult <- getUsageResult(resource)
} yield {
  yourSideEffectOn(resource) // will not wait if it returns a future
  mutate(usageResult)
}

如果我没记错的话，这也应该有效：

for {
  resource <- getResource()
  usageResult <- getUsageResult(resource)
  _ = yourSideEffectOn(resource) // will not wait if it returns a future
} yield mutate(usageResult)

如果你想等待副作用也完成（如果它失败了，就中断），你也可以平面映射副作用：

for {
  resource <- getResource()
  usageResult <- getUsageResult(resource)
  _ <- yourSideEffectOn(resource) // will wait for side effect to finish
} yield mutate(usageResult)