使用返回 Future 的函数映射 Stream

有时我发现自己处于这样的境地：Stream[X], and a function X => Future Y，我想组合成一个Future[Stream[Y]]，而且我似乎找不到办法做到这一点。例如，我有

val x = (1 until 10).toStream
def toFutureString(value : Integer) = Future(value toString)

val result : Future[Stream[String]] = ???

I tried

 val result = Future.Traverse(x, toFutureString)

它给出了正确的结果，但似乎在返回 Future 之前消耗了整个流，这或多或少地破坏了目的

I tried

val result = x.flatMap(toFutureString)

但这不能编译type mismatch; found : scala.concurrent.Future[String] required: scala.collection.GenTraversableOnce[?]

val result = x.map(toFutureString)

返回有点奇怪和无用的Stream[Future[String]]

我应该在这里做什么来解决问题？

编辑：我没有陷入困境Stream，我对在Iterator，只要在开始处理头部之前它不会阻止评估所有项目

Edit2：我不是 100% 确定 Future.Traverse 构造需要在返回 Future[Stream] 之前遍历整个流，但我认为确实如此。如果没有，这本身就是一个很好的答案。

Edit3：我也不需要结果按顺序排列，我对返回的流或迭代器的顺序很满意。

你走在正确的轨道上traverse，但不幸的是，在这种情况下，标准库的定义似乎有点被破坏——它不需要在返回之前消耗流。

Future.traverse是一个更通用函数的特定版本，适用于包装在“可遍历”类型中的任何应用函子（请参阅these http://www.cs.ox.ac.uk/people/jeremy.gibbons/publications/#iterator papers http://www.soi.city.ac.uk/~ross/papers/Applicative.html或我的答案here https://stackoverflow.com/a/12358892/334519例如，了解更多信息）。

The Scalaz https://github.com/scalaz/scalaz库提供了这个更通用的版本，在这种情况下它按预期工作（请注意，我正在获取适用函子实例Future from scalaz-contrib https://github.com/typelevel/scalaz-contrib;它还没有出现在 Scalaz 的稳定版本中，它仍然是针对 Scala 2.9.2 交叉构建的，而 Scala 2.9.2 没有这个Future):

import scala.concurrent._
import scalaz._, Scalaz._, scalaz.contrib.std._

import ExecutionContext.Implicits.global

def toFutureString(value: Int) = Future(value.toString)

val result: Future[Stream[String]] = Stream.from(0) traverse toFutureString

这会立即以无限流的形式返回，因此我们可以确定它不会首先被消耗。

作为脚注：如果你看来源 https://github.com/scala/scala/blob/v2.10.2/src/library/scala/concurrent/Future.scala#L577 for Future.traverse你会看到它的实现方式是foldLeft，这很方便，但对于流来说不是必需的或不合适的。