zio-sqs-2.scala

Stream.fromEffect {
  IO.effectAsync[Any, Throwable, List[Message]] { cb =>
    client
      .receiveMessage(ReceiveMessageRequest.builder.queueUrl(queueUrl).maxNumberOfMessages(10).build)
      .handle[Unit]((result, err) => {
        err match {
          case null => cb(IO.succeed(result.messages.asScala.toList))
          case ex   => cb(IO.fail(ex))
        }
      })
    ()
  }
}.forever
 .flatMap[Any, Throwable, Message](Stream.fromIterable)