我对使用ZIO非常陌生。我目前正在用Scala编写一个密码交易机器人,同时我也在尝试学习ZIO。现在我正在打开一个websocket,这个websocket会给出多个回调,直到它被关闭,我正在努力将其集成到我的代码中。我当前的代码: object Main extends zio.App with Logging { IO.suc
我必须在给定队列URL列表的情况下更新它以支持多个队列。run "handleMessage" up to 10 times concurrently, ZStream[Env, Throwable, Unit]
.runDrain // ZIO(ZIO,ZIO,ZIO),而我给了它一个(ZIO,ZIO,List)。我假设我必须将该列表中的所有效果减少到一个单独的效果中,该效果将在所有队列中并行执行handle