动态添加元素到fs2.Stream

Question

如何动态向 fs2.Stream 添加新元素？例如，我想将按下的按键作为流读取。我尝试使用 Stream.eval 以及内部使用foreverM 的函数来构建流，但事实证明这根本不是一个好主意。

Answer 1

一般来说，您不能将任何内容推送到 fs2.Stream。流是惰性的、基于拉动的结构，这意味着流按需请求下一个元素。

在这种特定情况下，您可以通过生成一个流来处理该问题，该流表示“当需要另一个元素时，读取控制台输入”。

import cats.effect.std.Console
def readNext: IO[String] = Console[IO].readLine // Or however else
val inputs = fs2.Stream.repeatEval(readNext)

---

当元素实际上必须是推送时，更通用的解决方案是推送元素使用 队列，然后 从队列创建流

---

第三种选择是使用 fs2-io 的 内置对控制台的支持，

fs2.io.stdinUtf8[F](bufferSize): Stream[F, String]