播放框架枚举器：如何使用索引压缩枚举器

Question

假设我有一个枚举器

val e: Enumerator[String] = Enumerator("a","b","c")

和另一个自然数的枚举数

val count = Enumerator.enumerate(Iterator.from(1))

我如何生成一个同时压缩它们的 Enumerator。或者用索引压缩 e。 所以在这种情况下输出是： val zipped: Enumerator[(String,Int)] = Enumerator(("a",1),("b",2),("c",3))

Answer 1

我对 Iteratees 有点陌生，但由于还没有回复，我将分享我的专业知识。

似乎应该有一个 zip 运算符来执行您所描述的操作。最接近的是interleave，但根据我对其行为的理解，我认为它不适合您的用例。

如果你只需要每个元素的索引，你可以使用这样的东西（我承认丑陋的可变状态）

scala> import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.ExecutionContext.Implicits.global

scala> import play.api.libs.iteratee._
import play.api.libs.iteratee._

scala> var counter = -1
counter: Int = -1

scala> Enumerator("a", "b", "c").map[(String, Int)]{ s => counter+=1; (s, counter) }
res1: play.api.libs.iteratee.Enumerator[(String, Int)] = play.api.libs.iteratee.Enumerator$$anon$3@3c0c6967

scala> res1 run Iteratee.foreach( println _ )
(a,0)
(b,1)
res2: scala.concurrent.Future[Unit] = scala.concurrent.impl.Promise$DefaultPromise@7814bb7d
(c,2)

scala>

如果您想要一些不会在 var 周围关闭的东西（您应该这样做！），您可以考虑在 iteratee 一侧实现此功能，并在 Step 进程中将计数器作为状态传递。