homework_7 - Страхов Ярослав

homeworks/homework_7/src/main/scala/Breakfast.scala

@@ -32,10 +32,25 @@ object Breakfast extends ZIOAppDefault {
   def makeBreakfast(eggsFiringTime: Duration,
                     waterBoilingTime: Duration,
                     saladInfoTime: SaladInfoTime,
-                    teaBrewingTime: Duration): ZIO[Any, Throwable, Map[String, LocalDateTime]] = ???
+                    teaBrewingTime: Duration): ZIO[Any, Throwable, Map[String, LocalDateTime]] = for {
+    eggs <- (ZIO.sleep(eggsFiringTime) *> ZIO.succeed(LocalDateTime.now())).fork
+    water <- (ZIO.sleep(waterBoilingTime) *> ZIO.succeed(LocalDateTime.now())).fork
+    salad <- (ZIO.sleep(saladInfoTime.cucumberTime) *>
+      ZIO.sleep(saladInfoTime.tomatoTime) *>
+      ZIO.succeed(LocalDateTime.now())).fork
+    waterTime <- water.join
+    teaTime <- ZIO.sleep(teaBrewingTime) *> ZIO.succeed(LocalDateTime.now())
+    eggsTime <- eggs.join
+    saladTime <- salad.join
+  } yield Map(
+    "eggs" -> eggsTime,
+    "water" -> waterTime,
+    "saladWithSourCream" -> saladTime,
+    "tea" -> teaTime
+  )
 
 
 
   override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] = ZIO.succeed(println("Done"))
 
-}
+}

homeworks/homework_7/src/main/scala/ResuourceTraining.scala

@@ -13,9 +13,23 @@ import java.io.{BufferedReader, BufferedWriter, FileReader, FileWriter}
 
 object ResuourceTraining extends ZIOAppDefault {
 
-  def readData(filePath: String): IO[Throwable, String] = ???
-
-  def writeData(filePath: String, data: String): ZIO[Any, Nothing, Unit] = ???
+  def readData(filePath: String): IO[Throwable, String] = {
+    ZIO.acquireReleaseWith(ZIO.attempt(
+      new BufferedReader(new FileReader(filePath))
+    ))(reader => ZIO.succeed(reader.close()))(
+      reader => ZIO.succeed(reader.readLine()))
+  }
+
+  def writeData(filePath: String, data: String): ZIO[Any, Nothing, Unit] = {
+    ZIO.acquireReleaseWith(ZIO.attempt(new BufferedWriter(new FileWriter(filePath))))(
+      writer => ZIO.attempt(writer.close()).orDie
+    )(
+      writer => ZIO.attempt {
+        writer.write(data)
+        writer.flush()
+      }
+    ).orDie
+  }
 
   override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] = ZIO.succeed("Done")
-}
+}