Print lines of file using ZStream

file_print.scala

import zio._

object PrintBytes extends App {
  import zio.stream._
  import zio.console._
  import zio.duration._

  val fileName = "src/main/resources/world-cities_csv.csv"

  def fileStream: StreamChunk[IOException, Byte] =
    Stream.fromInputStream(new FileInputStream(fileName), 10)

  override def run(args: List[String]): ZIO[zio.ZEnv, Nothing, Int] =
    fileStream.chunks
      .transduce(ZSink.utf8DecodeChunk)
      .chunkN(20)
    .tap(str => putStr(str.mkString) *> ZIO.sleep(1.second))
//      .mapM(str => putStr(str.mkString) *> ZIO.sleep(1.second).as(str))
//      .mapM(str => ZIO.sleep(1.second).as(str))
      .runDrain.fold(_ => 1, _ => 0)

}