scala - 有状态的函数管道

Question

代码解释了自己。

val s = Seq(1,1,1)
val res: Seq[Int] = s.map(...)
                     .check(count how many 1s, if > 2 throw Exception)
                     .map(...)

我正在寻找此问题的简单解决方案 check功能 。

我可以用 map和 closure计数和抛出，但我想要纯函数。

我可以用 filter和 size或 reduce ，但它返回一个值，并且不能通过以下映射恢复。

我如何制作 纯和 有状态 检查管道到管道 ?

Answer 1

抛出异常可以说是不纯粹的。如果您改为使用一元形式的错误处理，您将执行以下操作:

Option(s.map(foo)).
  filter(m => m.count(_ == 1) < 2).
  map{ s =>
    s.map(bar)
     .filter(baz)
     ...
  }

事实上，如果你想在管道中组合它，并且你不想添加额外的括号，这是必要的 match ，可以使用常用的 tap方法:

implicit class TapAnything[A](private val a: A) extends AnyVal {
  def tap[U](f: A => U): A = { f(a); a }
}

现在你可以

s.map(...)
 .tap(self => if (self.count(_ == 1) > 1) throw new Exception)
 .map(...)
 ...

(注意: private val + extends AnyVal 只是为了向编译器表明它应该尽量避免创建额外的对象来进行调用)。