scala - 如何处理 monix onErrorHandle 中抛出的未处理异常

Question

我正在使用 monix 任务，我正在 try catch Throwable，然后将其转换为自定义错误。我已删除/更改代码以使其简单且相关。这是代码(问题跟在代码片段之后):

import io.netty.handler.codec.http.HttpRequest
import monix.reactive.Observable
import io.netty.buffer.ByteBuf
import monix.eval.Task
import com.mypackage.Response


private[this] def handler(
      request: HttpRequest,
      body: Observable[ByteBuf]
  ): Task[Response] = {

    val localPackage = for {
      failfast <- Task.eval(1 / 0)
    } yield failfast

    // Failure case.
    localPackage.onErrorRecoverWith {
        case ex: ArithmeticException =>
          print(s"LOG HERE^^^^^^^^^^^^^^^")
          return Task.now(
            Response(HttpResponseStatus.BAD_REQUEST,
                     None,
                     None)
          )
    }.runAsync

    // Success case.
    localPackage.map { x => 
       x match {
        case Right(cool) =>
          Response(
            HttpResponseStatus.OK,
            None,
            cool
          )
        case Left(doesntmatter) => ???
      }
  }
}

我能够看到打印语句，但未返回预期的 Task.now(Response(...。相反，调用处理程序方法的方法抛出错误。如何我让它返回 Task[Response] 吗？

成功案例有效，失败案例无效。

编辑 #1:修复 scala 代码中的错误。

编辑 #2 这就是我修复它的方式。

    // Success case.
    localPackage.map { x => 
       x match {
        case Right(cool) =>
          Response(
            HttpResponseStatus.OK,
            None,
            cool
          )
        case Left(doesntmatter) => ???
      }
  }.onErrorRecoverWith {
        case ex: ArithmeticException =>
          print(s"LOG HERE^^^^^^^^^^^^^^^")
          return Task.now(
            Response(HttpResponseStatus.BAD_REQUEST,
                     None,
                     None)
          )
    }

我考虑的是 future ，忘记了任务的lazy eval 性质。我还了解了 CancellableFuture 值是如何在失败任务中被丢弃的。

Answer 1

您的 sample 有几个问题。

其中一个代码在 Scala 中无效:

val localPackage = for {
  failfast <- 1 / 0
} yield failfast

我猜你的意思是 Task.eval(1/0)。

此外，onErrorHandle 没有 Task 作为返回类型，您可能正在考虑 onErrorHandleWith。给它一个部分函数(即一个可以因匹配错误而抛出异常的函数)是一个非常糟糕的主意——如果你想匹配那个错误，那么更好的选择是 onErrorRecover 和 onErrorRecoverWith，以偏函数为参数。

所以这是一个示例:

import monix.eval._
import monix.execution.Scheduler.Implicits.global

val task = Task.eval(1 / 0).onErrorRecoverWith {
  case _: ArithmeticException => Task.now(Int.MinValue)
}

task.runAsync.foreach(println)
//=> -2147483648

希望这对您有所帮助。