scala future testing

console

RuntimeException t: Kaboom
IllegalArgumentException t: Kaboom
- testing

FutureTest.scala

import java.util.concurrent.Executors

import org.scalatest.FreeSpec

import scala.concurrent.{Future, Await, ExecutionContext}
import scala.concurrent.duration.DurationInt
import scala.util.Try

/**
 * @author Ben Whitehead
 */
class FutureTesting extends FreeSpec {

  "testing" in {
    implicit val exec = Executors.newFixedThreadPool(16)
    implicit val ctx = ExecutionContext.fromExecutorService(exec)

    val f: Future[String] = futureTest

    Try {Await.result(f, 1.minute)}
    ctx.shutdown()
    exec.shutdown()
  }

  def futureTest(implicit ctx: ExecutionContext): Future[String] = {
    val f = scala.concurrent.future {
      if (true) {
        throw new IllegalArgumentException("Kaboom")
      }
      "Hello"
    }

    f onFailure { case t: RuntimeException =>
      println(s"RuntimeException t: ${t.getMessage}")
      assert(condition = true)
    }

    f onFailure { case t: IllegalArgumentException =>
      println(s"IllegalArgumentException t: ${t.getMessage}")
      assert(condition = true)
    }

    f onSuccess { case v =>
      println(s"success: $v")
      assert(condition = false)
    }
    f
  }
}