scala - 如何从 Future[Iterator] 创建源？

Question

我有一个 Future[Iterator]。我想将此迭代器提供给我的 Stream。在这里，我仍然想像使用 Source.fromIterator 一样从 Iterator 构造一个 Source。

但是，由于 Future，我不能在这里使用 Source.fromIterator。

也许我可以使用 Source.fromFuture 但是当我尝试使用它时，在我的情况下，它似乎实际上并没有从 Iterator 创建一个 Source。来自文档:

/**
   * Starts a new `Source` from the given `Future`. The stream will consist of
   * one element when the `Future` is completed with a successful value, which
   * may happen before or after materializing the `Flow`.
   * The stream terminates with a failure if the `Future` is completed with a failure.
   */
  def fromFuture[T](future: Future[T]): Source[T, NotUsed] =
    fromGraph(new FutureSource(future))

Answer 1

您可以结合使用 Source.fromFuture、flatMapConcat 和 Source.fromIterator。例如:

val futIter = Future(Iterator(1, 2, 3))

val source: Source[Int, _] =
  Source.fromFuture(futIter).flatMapConcat(iter => Source.fromIterator(() => iter))