我正在尝试使用 monix 3.0.0-RC1 构建反应式应用程序。
例如 a 有一个 Int 的 Seq,而第二个元素是错误的。我可以Oservable.raiseError(...)
用来处理这个:
Observable.fromIterable(Seq(1,2,3))
.flatMap( i =>
if (i == 2) Observable.raiseError(new Exception("Wrong i"))
else Observable.pure(i)
)
.doOnNext(i => println(s"Processing $i"))
.foreachL(i => println(s"Finished $i"))
.onErrorHandle(_ => Task.unit)
我不喜欢上面代码中抛出的异常。
另一方面,我可以使用 Scala 的Either
:
Observable.fromIterable(Seq(1,2,3))
.map( i =>
if (i == 2) Left("Wrong i")
else Right(i)
)
.doOnNext(either => either.map( i => println(s"Processing $i") ))
.foreachL(either => either.map( i => println(s"Finished $i") ))
但either => either.map(...)
在每一步中都不爽。
处理错误的更好方法是什么?