zio-queue.scala

def listen(actorSystem: ActorSystem, topic: String): Task[Queue[String]] =
  for {
    queue      <- Queue.bounded[String](1000)
    rts        <- Task.runtime[Any]
    _          <- Task(actorSystem.actorOf(Props(new SubscriberActor(topic, rts, queue))))
  } yield queue
  
case class MessageEnvelope(msg: String)
  
class SubscriberActor(topic: String, rts: Runtime[Any], queue: Queue[String]) extends Actor {

  DistributedPubSub(actorSystem).mediator ! Subscribe(topic, self)

  def receive: PartialFunction[Any, Unit] = {
    case MessageEnvelope(s) => rts.unsafeRunSync(queue.offer(s))
  }
}