scala - 無限ストリームでエラーをスキップする

Question

fs2.Streamエラーが発生する可能性のある無限があります。何もせずにこれらのエラーをスキップし (おそらくログに記録)、さらに要素をストリーミングし続けたいと思います。例：

//An example
val stream = fs2.Stream
    .awakeEvery[IO](1.second)
    .evalMap(_ => IO.raiseError(new RuntimeException))

この特定のケースでは、毎秒無限fs2.Streamに放出したいと考えています。Left(new RuntimeException)

Stream.attempt最初のエラーが発生した後に終了したストリームを生成するメソッドがあります。エラーをスキップしてさらに要素を引き続ける方法はありますか?

これIO.raiseError(new RuntimeException).attemptは、ストリーム パイプライン構成のすべての場所ですべての効果を試す必要があるため、一般的には機能しません。