fs2practice.scala

fs2practice.scala

object Main extends App {
  import cats.effect.IO
  import fs2.{Stream, Sink}
  import scala.concurrent.ExecutionContext.Implicits.global

  val count = new java.util.concurrent.atomic.AtomicLong(0)
  val acquire = IO { println("incremented: " + count.incrementAndGet); () }
  val release = IO { println("decremented: " + count.decrementAndGet); () }

  val err = Stream.raiseError(new Exception("oh noes!"))

  val s =
    Stream.range(1, 10)
      .repeat
      .take(19)
      .segmentN(5)

  val z =
    Stream.bracket(acquire)(_ => s /*++ err*/, _ => release)
      .observe(Sink(x => IO(println("x => " + x.force.toList))))

  println(z.runLog.unsafeRunSync)
}