在 Akka/Scala 中使用带有 future 的 mapTo

2024-05-12

我最近开始使用 Akka/Scala 编码,遇到了以下问题:

通过范围内的隐式转换,例如:

implicit def convertTypeAtoTypeX(a: TypeA): TypeX =
    TypeX() // just some kinda conversion

这有效:

returnsAFuture.mapTo[TypeX].map { x => ... }

但这并没有:

returnsAFuture.mapTo[TypeX].onComplete { ... }

后者因类型转换异常而失败。 (即 Type 不能转换为 Type X)

很困惑。为什么?我怀疑这与 Try 有关,但我对这两者都了解不够,无法猜测任何答案:(

Thanks!


来自文档:

def mapTo[S](implicit tag: ClassTag[S]): Future[S]  
    Creates a new Future[S] which is completed with this Future's result if that conforms to S's erased type or a ClassCastException otherwise.

该函数只能用于在具有某种继承关系的对象之间进行转换。它不期望任何隐式证据从 [T] 转换为 [S](它甚至不知道 T!)

该功能用于例如在 Akka 中,你询问一个 actor 并收到 Future[Any] 的响应。但你知道 Actor 会返回 String,这样你就可以安全地编写actor.ask(...).mapTo[String]这会起作用,因为 Any 可以投射到一切。这里没有使用隐式转换。

现在你说你的第一个例子有效。但这条线甚至没有被计算,因为您从不请求结果。为了形象化,Scala 编译器说:好吧,你只是在这个 future 的结果上做一个映射(从类型 X 更改为类型 Y),但你从未真正使用它,所以如果你不这样做,为什么还要执行它呢?照顾你自己?

如果您在第一行的地图后面添加了 onComplete,您将看到相同的 ClassCastException。

这可能就是您现在想要的,但这很有趣:

returnsAFuture.map { x => x.fieldOnlyInTypeX }

如果您使用“x”,就好像它是 TypeX 类型一样,一切都会正常工作。 Scala 编译器将对“x”应用隐式转换,将其转换为 TypeX。这可能不是您想要的,因为“x”仍然是 TypeA 类型,并且在映射中每次使用时都会通过隐式转换。

〜克日谢克

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

在 Akka/Scala 中使用带有 future 的 mapTo 的相关文章

随机推荐