问题标签 [fs2]

我想知道如何将 Scala fs2 Stream 转换为字符串，来自 fs2 github 自述文件示例：

如何将结果获取到字符串而不是另一个文件？

我正在尝试使用 FS2 (0.10.0) 构建应用程序。我从文档中获取了这个例子：

但它在编译时失败：

恐怕我被卡住了，我不明白为什么会这样。任何的想法？

我遇到了 FS2 和异常处理的问题。我想要的是，给定一个Stream[IO,A]，当我使用一个f: A => B可以抛出异常的映射它时，我得到一个Stream[IO,Either[Throwable,B]].

我尝试了以下方法，它按预期工作：

它打印：

但是，当我尝试对此做任何事情时，我的问题就开始了Stream。

出现异常并终止应用程序：

更奇怪take的是，过去Stream只返回我知道没问题的元素，仍然以同样的方式爆炸：

任何人都可以澄清为什么会这样吗？这是错误还是（未）预期的行为？

注意此行为存在于 FS2 0.10.0-M7和0.10.0

我正在使用幻象连接到 Apache Cassandra 并希望在运行时配置连接器，即我想解析一些配置文件，提取 Cassandra 数据库列表并以某种方式将其传递给我的Database对象。

我按照本指南在我的服务DatabaseProvider之间增加了一层。Database因此，我可以提供这样的静态DatabaseProvider：

在我的main职能中，我做

如果没有单例对象，如何在运行时获得相同的结果？

我做了几次尝试，但总是得到NullPointerExceptions。我目前的方法是让杰克逊从文件中读取一个 Cassandra 配置对象：

然后我的入口点从fs2扩展StreamApp

这会导致以下错误：

为什么不能使用 Mockito 模拟来模拟返回 fs2.Stream 的方法？

Mockito 抱怨我试图返回 FreeC 而不是 Stream。为什么会这样，我怎样才能让它工作？

以下代码：

给出这个错误：

扩展StreamApp要求您提供stream定义。它有一个requestShutdown参数。

def stream(args: List[String], requestShutdown: F[Unit]): Stream[F, ExitCode]

我为此提供了实现，并理解它args是作为命令行参数传入的。但是，我不确定是什么提供了requestShutdown参数以及我可以用它做什么。

具体来说，我想在Stream[IO, ExitCode]启动 Http4s 服务器（永远阻塞）上调用正常关闭。

看起来 aSignal是必需的并且必须设置？我试图“获取”的底层流如下所示：

我的streamdef 在这里，StreamAppSpec从 fs2 项目中有一些东西，StreamAppSpec但我不知道如何适应它。

如何对元素进行分组？可能的解决方案：

• chunkLimit
• segmentLimit
• segmentN
• groupAdjecentBy

哪个不完全那样。

我正在寻找像在Akka Streams中分组的东西

我想解析一个输出集合的 json 文件A。的签名Output是IO[List[A]]

如何将此值转换为Stream: Stream[IO, A]？我可以转换为 aStream[IO, List[A]]但这不是我想要的

fs2.Stream.eval(input).flatMap(x => fs2.Stream.apply(x)) 谢谢

如何使用fs2filtered从当前流文件中删除行并获取过滤行数作为返回类型？

例如：如果old.txt包含由换行符 (\n) 分隔的字符串：

和val myList = List("chen","yval")。

想知道scala fs2流中块大小的增加是否会带来性能提升？