FS2 流一直运行到 InputStream 结束

Question

我是 FS2 的新手，需要一些有关设计的帮助。我正在尝试设计一个流，它将从底层InputStream 中提取块直到它结束。这是我尝试过的：

import java.io.{File, FileInputStream, InputStream}

import cats.effect.IO
import cats.effect.IO._

object Fs2 {

  def main(args: Array[String]): Unit = {
    val is = new FileInputStream(new File("/tmp/my-file.mf"))
    val stream = fs2.Stream.eval(read(is))
    stream.compile.drain.unsafeRunSync()
  }

  def read(is: InputStream): IO[Array[Byte]] = IO {
    val buf = new Array[Byte](4096)
    is.read(buf)
    println(new String(buf))
    buf
  }
}

程序打印唯一的第一个块。这是合理的。但我想找到一种方法来“指示”在哪里停止阅读以及在哪里停止。我的意思是一直打电话到read(is) 直到结束。有没有办法做到这一点？

我也尝试过repeatEval(read(is))，但它一直在读取...我需要介于两者之间的东西。

Answer 1

使用fs2.io.readInputStream 或fs2.io.readInputStreamAsync。前者阻塞当前线程；后者阻塞了ExecutionContext 中的一个线程。例如：

val is: InputStream = new FileInputStream(new File("/tmp/my-file.mf"))
val stream = fs2.io.readInputStreamAsync(IO(is), 128)