Scala中有类似Java Stream的“peek”操作吗?

2024-05-14

在Java中你可以调用peek(x -> println(x))在 Stream 上,它将对每个元素执行操作并返回原始流,这与 foreach 不同,foreach 是 Unit。 Scala 中是否有类似的东西,最好是适用于所有 Monady 类型的东西,允许您在执行副作用操作时“穿过”原始 Monad? (例如日志记录)

当然很容易实现:

def tap[A, U](a: A)(action: (A) => U): A = {
  action(a)
  a
}

但我希望有一些更优雅或更惯用的东西。


解决这个问题的一种方法是使用隐式:

class Tappable[A](a: A) {
  def tap[U](action: (A) => U): A = {
    action(a)
    a
  }
}

implicit def any2Tappable[A](a: A): Tappable[A] = new Tappable[A](a)

然后可以在本地使用:

connection.tap(_.connect()) match {
  case c if c.getResponseCode == 304 => None
  ...

还有其他答案吗?

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Scala中有类似Java Stream的“peek”操作吗? 的相关文章

随机推荐