import fs2._
import cats.effect.IO
import scala.concurrent.ExecutionContext
import scala.concurrent.duration._

implicit val cs = IO.contextShift(ExecutionContext.global)
implicit val ce = IO.ioConcurrentEffect

val source = Stream[IO, Int](1, 2, 3, 4, 5).covary[IO]

val program =
  fs2.concurrent.Queue
    .unbounded[IO, Int]
    .flatMap { queue =>
      (source.through(queue.enqueue).drain ++
        queue.dequeue
          .evalTap(el => IO(println(s"$el was in the queue")))
          .takeThrough(_ < 3)
          .evalTap(el => IO(println(s"$el was taken from the stream")))
          .drain ++
        Stream
          .eval(queue.dequeue1)
          .evalTap(el => IO(println(s"The queue still contains $el")))).compile.last
    }

program.unsafeRunTimed(10.second).flatten