FuturesWithRecover.scala

import java.util.concurrent.Executors

import scala.concurrent.{ExecutionContext, Future}

object Main extends App {

  val executorService = Executors.newFixedThreadPool(5)

  implicit val executionContext: ExecutionContext = ExecutionContext.fromExecutorService(executorService)

  for {

    x <- Future {
      Thread.sleep(500)
      Right(1)
    } recover {
      case throwable => Left(throwable)
    }
    y <- Future {
      throw new RuntimeException("yea")
    } recover {
      case throwable => Left(throwable)
    }
    z <- Future {
      Thread.sleep(100)
      Right(2)
    } recover {
      case throwable => Left(throwable)
    }

  } yield {
    println(x, y, z)
    executorService.shutdown()
  }

}