scala - 代数提供时是否可以停止所有流?
问题描述
我有以下返回的特征fs2.Stream
trait Test {
def action(arg: Int): fs2.Stream[IO, Unit]
}
返回fs2.Stream
的 s 是无限的,因此应该能够阻止它们。给定一个实现trait Test
是否有可能创建一个Resource[IO, Test]
停止def action(arg: Int): fs2.Stream[IO, Unit]
发布时返回的所有流?
解决方案
推荐阅读
- jmeter - 如何实现对smpp协议的性能测试
- vue-component - Vue.js 组件中的文件阅读器进度
- lambda - 如何在集合和数组列表上使用 lambda 表达式
- api - 我无法使用 ApiVersioning .net Core 在响应标头中显示 API 版本
- gmail - Gmail 会呈现 amp 电子邮件中使用的任何字体吗?
- r - 检索带有标签/级别的因子作为具有最大值的 colname。水平下降问题
- unix - 如何将 grep 与管道一起使用?
- angular - TinyMCE中带有动态数据的Angular 9和自定义按钮
- hadoop - 找不到适合 jdbc:hive2 的驱动程序
- python - Python - InvalidArgumentException