scalaj-http - 'execute‘方法返回“流已关闭”

Question

我想使用scalaj-http库从http连接下载一个31 to大小的字节内容文件。'asBytes‘不是一个选项，因为它返回一个字节数组。

我试图使用' execute‘方法返回输入流，但当我执行下面的程序时，它返回流已关闭。我不认为我读了两次流。

我做错了什么？

  val response: HttpResponse[InputStream] = Http(url).postForm(parameters).execute(inputStream => inputStream)

  if (response.isError) println(s"Sorry, error found: ${response.code}")
  else {
    val is: InputStream = response.body
    val buffer: Array[Byte] = Array.ofDim[Byte](1024)
    val fos = new FileOutputStream("xxx")
    var read: Int = 0

    while (read >= 0) {
      read = is.read(buffer)
      if (read > 0) {
        fos.write(buffer, 0, read)
      }
    }
    fos.close()
  }

Answer 1

不能导出inputStream，因为流将在execute方法结束时关闭。您应该在execute中使用流，如下所示：

  val response = Http(url).postForm(parameters).execute { is =>         
    val buffer: Array[Byte] = Array.ofDim[Byte](1024)
    val fos = new FileOutputStream("xxx")
    var read: Int = 0

    while (read >= 0) {
      read = is.read(buffer)
      if (read > 0) {
        fos.write(buffer, 0, read)
      }
    }
    fos.close()
  }

  if (response.isError) println(s"Sorry, error found: ${response.code}")