Scala将元组向量映射到对象向量

Question

import scala.concurrent.duration._
import scala.language.implicitConversions
import scala.concurrent.{Future, Await}
import scala.concurrent.ExecutionContext.Implicits.global

object test extends App {  
  case class Person(name: String, age: Int)

  implicit def t2p(t: (String, Int)) : Person = Person(t._1, t._2)

  val f:Future[Vector[(String, Int)]] = Future {
    Vector(("One", 1), ("Two", 2))
  }

  val s = f.mapTo[Vector[Person]]

  Await.result(s.map { _ foreach { x => println(x)}}, 5.seconds)
}

我试图将元组向量转换为向量[人]，但上面的html" target="_blank">代码会导致强制转换异常，即使存在隐式的元组-人转换函数？

线程“main”java中出现异常。lang.ClassCastException：scala。Tuple2无法转换为示例。例如，测试$人。测试$$anonfun$2$$anonfun$应用$1。在scala应用（测试scala:19）。收集迭代器$类。scala上的foreach（迭代器。scala:727）。收集抽象迭代器。scala上的foreach（迭代器。scala:1157）。收集IterableLike$类。scala的foreach（IterableLike.scala:72）。收集可抽象。例如foreach（Iterable.scala:54）。测试$$anonfun$2。在示例中应用（测试scala:19）。测试$$anonfun$2。应用（测试scala：19）

谢谢

Answer 1

直接使用：

  val f:Future[Vector[Person]] = Future {
    Vector(("One", 1), ("Two", 2))
  }

您可以查看此答案以获取有关将mapTo与Futures一起使用的更多信息：将mapTo与Akka/Scala中的期货一起使用

Answer 2

这是mapTo的签名：

def mapTo[S](implicit tag: ClassTag[S]): Future[S]

它不需要任意的转换函数。删除t2p，代码仍会以同样的方式编译并失败<代码>映射到实际上执行Java样式转换，这就是为什么它需要类标记的原因。

相反，您可以这样做：

val s = f.map(vec => vec.map(Person.tupled))

Answer 3

mapTo只是尝试强制转换，因此尝试将Vector[（String， Int）]强制转换为Vector[Person]当然会失败。

您需要一个将（String，Int）转换为人的函数，该函数是人的元组版本。应用。

因此，更换

f.mapTo[Vector[Person]]

具有

f.map(_.map(Person.tupled))