0

我创建了一个简单的迭代器来使用 WS 下载文件，如此链接中所述。

考虑以下代码段：

import java.nio.ByteBuffer
import java.nio.channels.FileChannel
import org.specs2.mutable.Specification
import org.specs2.time.NoTimeConversions
import play.api.libs.Files.TemporaryFile
import play.api.libs.iteratee.{Done, Input, Cont, Iteratee}
import play.api.libs.ws.WS
import scala.concurrent.Await
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global

class DummySpec extends Specification with NoTimeConversions {
  def fileChannelIteratee(channel: FileChannel): Iteratee[Array[Byte], Unit] = Cont {
    case Input.EOF =>
      println("Input.EOF")
      channel.close()
      Done(Unit, Input.EOF)
    case Input.El(bytes) =>
      println("Input.El")
      val buf = ByteBuffer.wrap(bytes)
      channel.write(buf)
      fileChannelIteratee(channel)
    case Input.Empty =>
      println("Input.Empty")
      fileChannelIteratee(channel)
  }

  "fileChannelIteratee" should {
    "work" in {
      val file = TemporaryFile.apply("test").file
      val channel = FileChannel.open(file.toPath)

      val future = WS.url("http://www.example.com").get(_ => fileChannelIteratee(channel)).map(_.run)

      Await.result(future, 10.seconds)

      file.length !== 0
    }
  }
}

在 WS.get 之后调用 .map(_.run) 似乎在这里没有效果，因为 iteratee 似乎没有收到 Input.EOF。它使我无法关闭频道。这是我得到的输出：

Input.El
[info] DummySpec
[info]
[info] fileChannelIteratee should
[info] x work (941 ms)
[error]    '0' is equal to '0' (DummySpec.scala:37)
[info]
[info]
[info] Total for specification DummySpec
[info] Finished in 948 ms
[info] 1 example, 1 failure, 0 error

我究竟做错了什么？

我正在使用 Play Framework 2.2.2。

提前致谢。

4

1 回答 1

0

我以错误的方式打开 FileChannel。当没有给出参数时，似乎默认为根据此链接读取模式。

由于整个操作的返回类型是 ，所以抛出的异常被channel.write操作吞噬。在这种情况下，即使内部失败，外部也处于成功状态。应改为使用。mapFuture[Future[Unit]]FutureflatMap

于 2014-03-26T14:44:09.950 回答