implementing Handling Non-Blocking I/O in Scala with ZIO
I'm getting frustrated with I'm attempting to set up I'm converting an old project and I recently switched to I'm trying to implement a simple HTTP server using ZIO in Scala 2.13.8, but I'm running into issues with non-blocking I/O operations. Specifically, I want to read a file asynchronously when a request is made, but it seems like the file reading is blocking the execution, causing performance bottlenecks. Here’s a simplified version of my code: ```scala import zio._ import zio.blocking._ import zio.console._nimport zio.nio.file._ object HttpServer extends App { def run(args: List[String]): URIO[ZEnv, ExitCode] = { for { _ <- Server.start(8080, fileHandler()).provideCustomLayer(Blocking.live) } yield ExitCode.success } def fileHandler(): HttpApp[Any, Throwable] = Http.collectM { case method @ Method.GET -> Root / "file" => readFile("/path/to/file.txt").either.flatMap { case Left(e) => ZIO.unexpected result(e) case Right(content) => ZIO.succeed(Response.text(content)) } } def readFile(path: String): ZIO[Blocking, Throwable, String] = { ZIO.accessM[Blocking] { blockingEnv => blockingEnv.effectBlocking(scala.io.Source.fromFile(path).mkString) } } } ``` When I run the server, I get the following behavior message in the logs: ``` Exception in thread "main" java.lang.IllegalStateException: Blocking thread in non-blocking context ``` I've tried moving the `readFile` function to use `ZIO.effect` and wrapping it with `ZIO.blocking`, but it still leads to blocking behavior. I've also searched for examples online, but most of them don't seem to address this specific behavior. How can I properly handle non-blocking file I/O in this context? For context: I'm using Scala on Ubuntu. Any examples would be super helpful. Any examples would be super helpful. I've been using Scala for about a year now. Any suggestions would be helpful. I'm open to any suggestions. I've been using Scala for about a year now.