Scala、ZIO-如何将ZIO转换为Task并获得结果?
我有一个返回一些 ZIO 的方法:
def method(...): ZIO[Any with clock, SomeError, Unit]
调用此返回的方法Task[Unit]:
def otherMethod(..): Task[Unit] = {
ZIO.effect(method(...))
}
问题是当我调用它时ZIO.effect我没有得到结果。我应该如何转换ZIO,以Task获得结果呢?
回答
随着ZIO.effect(method(...)) 你得到一个Task[ZIO[...]]很少是你想要的(它在概念上类似于嵌套Future[Future[A]])。
为了将 aZIO[R, E, A]变成 a Taks[A],您必须了解后者只是 for 的类型别名ZIO[Any, Throwable, A],这表明您必须
- 消除对环境的依赖
R(通过提供) - 如果错误类型还不是它的子类型(例如 by )
E,Throwable则将错误类型转换为.mapError
这应该有效:
def otherMethod(..): Task[Unit] =
method(...)
.mapError(someError => new RuntimeException(s"failed with: $someError"))
.provideLayer(Clock.live)
- Small point but conceptually it is more similar to a `Future[() => Future[A]]` since a `Future[Future[A]]` is already processing even if not flattened, whereas `Task[Task[A]]` will do no meaningful work unless it gets flattened