Initial commit

Author: mtumilowicz

.gitignore

@@ -0,0 +1,5 @@
+# Project exclude paths
+/project/target/
+/target/
+/target/scala-2.13/classes/
+/target/scala-2.13/test-classes/

build.sbt

@@ -0,0 +1,14 @@
+ThisBuild / scalaVersion     := "2.13.10"
+ThisBuild / version          := "0.1.0-SNAPSHOT"
+ThisBuild / organization     := "com.example"
+ThisBuild / organizationName := "example"
+
+lazy val root = (project in file("."))
+  .settings(
+    name := "zio2-fiber-workshop",
+    libraryDependencies ++= Seq(
+      "dev.zio" %% "zio" % "2.0.6",
+      "dev.zio" %% "zio-test" % "2.0.6" % Test
+    ),
+    testFrameworks += new TestFramework("zio.test.sbt.ZTestFramework")
+  )

project/build.properties

@@ -0,0 +1 @@
+sbt.version = 1.8.2

src/main/scala/app/Main.scala

@@ -0,0 +1,38 @@
+package app
+
+import zio._
+
+import java.io.IOException
+
+object Main extends ZIOAppDefault {
+  def program(queue: Queue[String]) = {
+    def loop(sayingBackgroundFiber: Ref[Fiber.Runtime[IOException, Long]]): Task[Unit] = for {
+      read <- queue.take
+      _ <- sayingBackgroundFiber.get.flatMap(_.interrupt)
+      fork <- sayPlease.delay(Duration.fromSeconds(10)).fork
+      _ <- sayingBackgroundFiber.set(fork)
+      _ <- Console.printLine(s"wrote: $read")
+      _ <- loop(sayingBackgroundFiber)
+    } yield ()
+
+    for {
+      fiber2 <- sayPlease.fork
+      _ <- ZIO.sleep(100.millis)
+      ref <- Ref.make(fiber2)
+      _ <- loop(ref)
+    } yield ()
+  }
+
+  val sayPlease = Console.printLine("say sth plz").repeat(Schedule.spaced(Duration.fromSeconds(1)))
+  def say(queue: Queue[String]) = for {
+    read <- Console.readLine
+    _ <- queue.offer(read)
+  } yield ()
+
+
+  override def run: ZIO[Environment with ZIOAppArgs with Scope, Any, Any] = for {
+    queue <- Queue.bounded[String](100)
+    _ <- say(queue).fork
+    _ <- program(queue)
+  } yield ()
+}

src/test/scala/app/MainSpec.scala

@@ -0,0 +1,39 @@
+package app
+
+import zio.test.TestAspect.repeats
+import zio.test.{Spec, TestClock, TestConsole, TestEnvironment, ZIOSpecDefault, assertTrue}
+import zio.{Queue, Scope, durationInt}
+
+object MainSpec extends ZIOSpecDefault {
+  override def spec: Spec[TestEnvironment with Scope, Any] = suite("a")(
+    test("b") {
+      assertTrue("a" == "a")
+    },
+    test("c") {
+      for {
+        queue <- Queue.bounded[String](100)
+        _ <- queue.offer("a")
+        _ <- Main.program(queue).fork
+        _ <- TestClock.adjust(9.seconds)
+        output <- TestConsole.output
+      } yield assertTrue (output == Vector("say sth plz\n", "wrote: a\n"))
+    },
+    test("d") {
+      for {
+        queue <- Queue.bounded[String](100)
+        _ <- queue.offer("a")
+        _ <- Main.program(queue).fork
+        _ <- TestClock.adjust(11.seconds)
+        output <- TestConsole.output
+      } yield assertTrue(output == Vector("say sth plz\n", "wrote: a\n", "say sth plz\n"))
+    },
+    test("d") {
+      for {
+        queue <- Queue.bounded[String](100)
+        _ <- Main.program(queue).fork
+        _ <- TestClock.adjust(9.seconds)
+        output <- TestConsole.output
+      } yield assertTrue(output.count(_ == "say sth plz\n") == 10)
+    }
+  ) @@ repeats(50)
+}