Merge pull request #1109 from GiganticMinecraft/develop

バージョン 8 リリース
GiganticMinecraft · Jul 22, 2021 · b1c9e10 · b1c9e10
2 parents bc5eaf2 + fb99db2
commit b1c9e10
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 6 deletions.
diff --git a/build.sbt b/build.sbt
@@ -6,7 +6,7 @@ import java.io._
 ThisBuild / scalaVersion := "2.13.1"
 // ThisBuild / version はGitHub Actionsによって自動更新される。
 // 次の行は ThisBuild / version := "(\d*)" の形式でなければならない。
-ThisBuild / version := "7"
+ThisBuild / version := "8"
 ThisBuild / organization := "click.seichi"
 ThisBuild / description := "ギガンティック☆整地鯖の独自要素を司るプラグイン"
 

diff --git a/src/main/scala/com/github/unchama/generic/effect/stream/ReorderingPipe.scala b/src/main/scala/com/github/unchama/generic/effect/stream/ReorderingPipe.scala
@@ -47,7 +47,6 @@ object ReorderingPipe {
    *
    * 与えられたストリームの最初のChunkの極小の [[TimeStamped.currentStamp]] よりも
    * タイムスタンプが古い要素は返されるストリームに出力されない。
-   * また、そのような要素が存在した場合、返されるストリームは終了しない。
    */
   def apply[F[_], A]: Pipe[F, TimeStamped[A], A] =
     in => StreamExtra.uncons(in).flatMap { case (firstChunk, rest) =>

diff --git a/src/main/scala/com/github/unchama/generic/effect/stream/StreamExtra.scala b/src/main/scala/com/github/unchama/generic/effect/stream/StreamExtra.scala
@@ -92,13 +92,17 @@ object StreamExtra {
   /**
    * 与えられたストリームを、エラーが発生したときに再起動するストリームに変換してコンパイルする。
    */
-  def compileToRestartingStream[F[_] : Async : ErrorLogger, A](stream: Stream[F, _]): F[A] =
+  def compileToRestartingStream[F[_] : Async : ErrorLogger, A](stream: Stream[F, _]): F[A] = {
     stream
       .handleErrorWith { error =>
         Stream.eval {
-          ErrorLogger[F].error(error)("fs2.Stream が予期せぬエラーで終了しました。再起動します。")
-        }.append(stream)
+          ErrorLogger[F]
+            .error(error)("fs2.Stream が予期せぬエラーで終了しました。再起動します。")
+        }
       }
-      .compile.drain
+      .repeat
+      .compile
+      .drain
       .flatMap(_ => Async[F].never[A])
+  }
 }