4

我目前正试图围绕 and 的想法来Enumerators思考Iteratees。我决定从查看 Play 2.0 的 iteratee 库开始，我已将其添加到我的测试项目中，并在我的build.sbt文件中添加了以下行。（我使用的是 Scala 2.10）（此处的文档）

resolvers += "Typesafe repository" at 
  "http://repo.typesafe.com/typesafe/releases/"

libraryDependencies += "play" %% "play-iteratees" % "2.1.1"

我的目标是在文件的字节上创建一个枚举器，并最终为其附加一些解析逻辑，但是当我尝试看似简单的事情时，我得到了一个异常。我的代码如下所示：

val instr = getClass.getResourceAsStream(...)
val streamBytes = for {
  chunk <- Enumerator fromStream instr
  byte <- Enumerator enumerate chunk
} yield byte

val printer = Iteratee.foreach[Byte](println)

streamBytes.apply(printer)

发生的事情是（我假设是）文件中的所有字节都被打印出来，然后我得到一个IllegalStateException说法，“承诺已经完成”。

java.lang.IllegalStateException: Promise already completed.
    at scala.concurrent.Promise$class.complete(Promise.scala:55)
    at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:58)
    at scala.concurrent.Promise$class.failure(Promise.scala:107)
    at scala.concurrent.impl.Promise$DefaultPromise.failure(Promise.scala:58)
    at scala.concurrent.Future$$anonfun$flatMap$1.liftedTree3$1(Future.scala:283)
    at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:277)
    at scala.concurrent.Future$$anonfun$flatMap$1.apply(Future.scala:274)
    at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:29)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
    at java.lang.Thread.run(Thread.java:722)

由于堆栈跟踪没有指向我的代码中的任何地方，而且这是一个不熟悉的领域，我不知道出了什么问题。任何人都可以为这个问题提供一些见解或解决方案吗？

4

1 回答 1

1

看看这是否适合你。我的代码也出现异常，但是当我解开你的 for-comp 时，一切正常。我不是 100% 确定为什么，因为我认为 for-comp 无论如何都与此代码脱糖，但我一定遗漏了一些东西：

val bytes = Enumerator fromStream instr flatMap (Enumerator enumerate _)    
val printer = Iteratee.foreach[Byte](b => println(b))    
bytes |>> printer
于 2013-05-31T14:02:09.603 回答