scala - 代数提供时是否可以停止所有流？

Question

我有以下返回的特征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]发布时返回的所有流？