我对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)),但它一直在读.我需要些中间的东西。
发布于 2018-05-24 18:28:43
使用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)https://stackoverflow.com/questions/50515613
复制相似问题