CanHandleError

CanHandleError

CanHandleError is a typeclass to handle NonFatal Throwable and to recover from it. It looks like this.

trait CanHandleError[F[_]] {

  def handleNonFatalWith[A, AA >: A](
      fa: => F[A]
    )(
      handleError: Throwable => F[AA]
    ): F[AA]

  def handleEitherTNonFatalWith[A, AA >: A, B, BB >: B](
      efab: => EitherT[F, A, B]
    )(
      handleError: Throwable => F[Either[AA, BB]]
    ): EitherT[F, AA, BB]

  def handleNonFatal[A, AA >: A](
      fa: => F[A]
    )(
      handleError: Throwable => AA
    ): F[AA]

  def handleEitherTNonFatal[A, AA >: A, B, BB >: B](
      efab: => EitherT[F, A, B]
    )(
      handleError: Throwable => Either[AA, BB]
    ): EitherT[F, AA, BB]

}

There are instances available for monix.eval.Task, scala.concurrent.Future and cats.Id.

CanHandleError.handleNonFatal

import cats._
import monix.eval._

import effectie.monix._
import effectie.monix.Effectful._

import scala.util.control.NonFatal

class InvalidNumberException(n: Int, message: String) extends RuntimeException(message)

def foo(n: Int): Int = 
  if (n < 0)
    throw new InvalidNumberException(n, s"n cannot be a negative Int. n: $n") 
  else
     n

def bar[F[_]: Fx: CanHandleError](n: Int): F[Int] =
  CanHandleError[F].handleNonFatalWith(effectOf(foo(n))) {
    case NonFatal(err) =>
      pureOf(0)
  }
  
import monix.execution.Scheduler.Implicits.global
  
println(bar[Task](1).runSyncUnsafe())
// 1
println(bar[Task](-1).runSyncUnsafe())
// 0
 
println(bar[Id](1))
// 1
println(bar[Id](-1))
// 0

import effectie.monix._
import effectie.monix.Effectful._

import scala.util.control.NonFatal

import effectie.concurrent.ExecutorServiceOps
import java.util.concurrent.{ExecutorService, Executors}
import scala.concurrent.{ExecutionContext, Future, Await}
import scala.concurrent.duration._

object MyApp {
    
  class InvalidNumberException(n: Int, message: String) extends RuntimeException(message)
  
  def foo(n: Int): Int = 
    if (n < 0)
      throw new InvalidNumberException(n, s"n cannot be a negative Int. n: $n") 
    else
       n
  
  def bar[F[_]: Fx: CanHandleError](n: Int): F[Int] =
    CanHandleError[F].handleNonFatalWith(effectOf(foo(n))) {
      case NonFatal(err) =>
        pureOf(0)
    }

  def main(args: Array[String]): Unit = {
    
    val executorService: ExecutorService =
      Executors.newWorkStealingPool(Runtime.getRuntime.availableProcessors() >> 1)
    implicit val ec: ExecutionContext = ExecutionContext.fromExecutorService(executorService)
    
    try {
      println(Await.result(bar[Future](1), 1.second))
      println(Await.result(bar[Future](-1), 1.second))
    } finally {
      ExecutorServiceOps.shutdownAndAwaitTermination(executorService, 1.second)
    }
  }
}

MyApp.main(Array.empty)
// 1
// 0