zio-streams-mapMParUnordered.scala

package gc.demo

import com.typesafe.scalalogging.LazyLogging
import zio._
import zio.stream._

object Zio2App extends App with LazyLogging {

  override def run(args: List[String]): ZIO[ZEnv, Nothing, Int] = {

    Stream("a", "b", "c")
      .map(it => Either.cond(it == "a", it, new RuntimeException("invalid key")))
      .mapMParUnordered(4)(it => ZIO.fromEither(it))
      .run(Sink.drain)
      .foldM(
        e => {
          ZIO.effectTotal(logger.error("Application failed", e)) *> ZIO.succeed(1)
        },
        _ => {
          ZIO.succeed(0)
        }
      )

  }

}