如何使用redisson和ZIO监听redis列表事件

import org.redisson.Redisson
import org.redisson.api.{RList, RedissonClient}
import org.redisson.config.Config
import zio.{App, ZIO}
import zio.console._

object RedisListListener extends App {

  val redisConfig: Config = new Config()
  redisConfig.useSingleServer().setAddress("redis://localhost:6379")

  val redissonClient: RedissonClient = Redisson.create(redisConfig)
  val list: RList[String] = redissonClient.getList("mylist")

  val listener: String => Unit = element => println(s"New element added: $element")

  val effect = ZIO.effectAsync[Any, Throwable, Unit] { callback =>
    list.addListener(listener)
    callback(ZIO.unit)
  }

  override def run(args: List[String]): ZIO[zio.ZEnv, Nothing, Int] =
    effect.foldM(
      error => putStrLn(s"Error occurred: $error") *> ZIO.succeed(1),
      _ => putStrLn("Listening to Redis list events...") *> ZIO.succeed(0)
    )
}