问题标签 [fs2]

我正在尝试为 ammonite REPL 创建一个 predef.sc 文件。这是我写的

但它给了我一个错误说

我认为是因为 fs2 还有一个名为“io”的子包

Doobie select 返回一个fs2.Stream(doobie.ConnectionIO, String). 如果我们需要将其写入文件，显而易见的选择是调用stream.compile.toList.transact(transactor)然后将此列表保存到文件中。

有没有办法以流方式保存结果而不将其转换为列表？

我有一个List[IO[Unit]]由IO. 我想把它转换成Stream[IO,Unit]

目前，我所做的是这个

有没有更好的办法？

假设我有val fs2Stream: Stream[IO, Byte]并且我需要，例如，调用一些需要java.io.InputStream.

我想我对 FS2 太陌生了，但我似乎找不到答案。我试过使用fs2.io.toInputStream，fs2.io.readInputStream但我不知道如何提供一些必需的参数。我已经在全能的谷歌上搜索了答案，但自从大多数人最后一次寻找答案以来，API 似乎已经发生了变化。

我该如何做以下事情？

我正在尝试创建一个 Stream[Eval, String] 如下：

但问题是我得到一个编译错误说：

我似乎无法得到错误？我错过了什么？错误指的是什么？

我是一个新手，试图掌握 fs2 队列背后的直觉。我正在尝试做一个从Stream[IO, Int]. 但对我来说，文档还不够，因为它直接深入到高级内容。

这是我到目前为止所做的：

问题 1：我No implicit argument of type Concurrent[F_], 知道我没有使用任何并发效果我似乎无法弄清楚我错过了什么？

问题 2：如何打印结果。

问题3：有人可以指导我学习fs2的一些资源吗

我正在对队列进行一些基本测试，我想在队列出队之前添加一个服务时间。例如，服务时间没有定义，这将是 3 秒的平均值，它可能因元素而异。

有人可以提供一些启示吗？

这是我正在尝试做的事情：例如，对于 1，可能需要 3 秒，对于 2 可能需要 5 秒，对于 3 可能需要 4 秒......这个想法是平均服务时间，例如 4 秒......

我正在探索 fs2 库并进行测试，我有一个 Stream[IO, Int] 被推入队列 [IO,(Double, String, String, String)]。我需要确定进入队列的时间以及退出时间。

这里的问题是处理时间可能因元素而异。为此，我想到了使用.metered((Random.between(1,10)).seconds) 问题是我无法找到一种方法来存储入队时的进入时间和在给定的一定时间后的退出时间.metered((Random.between(1,10)).seconds)

这是我尝试过的：

用于识别当前时间的方法实现如下

问题：如何跟踪进入和退出时间以构建新的输出流？

我正在尝试处理一些任务。任务所花费的时间可能因元素而异。例如，1 从队列中存储和获取元素可能需要 11 秒，而2可能需要 30 秒......

我已经尝试为此使用计时器，但我仍然得到 entryTime = ExitTime 我想知道我错过了什么。

这是我尝试过的：

currentTimeNow 方法给出：

队列中的顺序处理。有多种方法fs2.Stream可以管理元素的发射方式。 fixedRate, fixedDelay, awakeEvery, awakeDelay. 我想要一个顺序处理。例如，没有元素被推入队列，直到其中的元素被拉出。

我发现 fixedDelay 方法可以做到这一点，但是当我使用它时，它并没有按预期工作。这是我尝试过的：

我得到这个：

预期输出：