scalatest-fun.scala

import java.util.concurrent.Executors

import cats.effect._
import fs2._
import org.scalatest.{FlatSpec, MustMatchers}

import scala.concurrent.duration._
import scala.concurrent.ExecutionContext

class TestNStuff extends FlatSpec with MustMatchers {

  def bracketEC =
    Stream.bracket(IO(
      ExecutionContext.fromExecutorService(Executors.newFixedThreadPool(10))))(
      Stream.emit(_),
      s => IO(s.shutdown())
    )

  val initializeStuff = for {
    sc <- Scheduler[IO](1)
    pool <- bracketEC
  } yield (sc, pool)

  initializeStuff.evalMap {
    case (sc, pool) =>
      implicit val p = pool
      IO {
        behavior of "wtf"

        it should "not explode" in {

          sc.sleep[IO](1.second).map(_ =>
            1
          ).compile.last.unsafeRunSync() mustBe (1)

        }
      }
  }.compile.drain.unsafeRunSync()

}