如何终止从 SBT Shell 启动的 FS2 流?

问题描述

如果我从 SBT shell 运行这个程序,然后取消它,它会继续打印“hello”。我必须退出 SBT 才能让它停止。这是为什么?

import cats.effect.{ExitCode,IO,IOApp}
import fs2.Stream
import scala.concurrent.duration._

object FS2 extends IOApp {

  override def run(args: List[String]) = 
      Stream.awakeEvery[IO](5.seconds).map { _ =>
        println("hello")
      }.compile.drain.as(ExitCode.Error)
}

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)