typelevel#1987 format fixed

dmitriibundin · Aug 14, 2020 · 0b203da · 0b203da
1 parent 8ad16ae
commit 0b203da
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 7 deletions.
diff --git a/core/shared/src/main/scala/fs2/Stream.scala b/core/shared/src/main/scala/fs2/Stream.scala
@@ -1924,9 +1924,11 @@ final class Stream[+F[_], +O] private[fs2] (private val free: FreeC[F, O, Unit])
                 ): F2[Unit] =
                   Semaphore(1).flatMap {
                     guard => // guarantee we process only single chunk at any given time from any given side.
-                      Stream.repeatEval(guard.acquire).zipRight(s.chunks)
+                      Stream
+                        .repeatEval(guard.acquire)
+                        .zipRight(s.chunks)
                         .evalMap { chunk =>
-                            resultQ.enqueue1(Some(Stream.chunk(chunk).onFinalize(guard.release)))
+                          resultQ.enqueue1(Some(Stream.chunk(chunk).onFinalize(guard.release)))
                         }
                         .interruptWhen(interrupt.get.attempt)
                         .compile

diff --git a/core/shared/src/test/scala/fs2/StreamMergeSuite.scala b/core/shared/src/test/scala/fs2/StreamMergeSuite.scala
@@ -190,11 +190,19 @@ class StreamMergeSuite extends Fs2Suite {
   test("merge not emit ahead") {
     forAllF { (v: Int) =>
       val expected = List(v, v + 1)
-      Ref.of[IO, Int](v).map(ref => {
-        Stream.repeatEval(ref.get).merge(Stream.never[IO]).evalMap(value => {
-          IO.sleep(100.milliseconds) >> ref.set(value + 1) >> IO(value)
-        }).take(2)
-      }).flatMap(_.compile.toList).map(result => assert(result == expected))
+      Ref
+        .of[IO, Int](v)
+        .map { ref =>
+          Stream
+            .repeatEval(ref.get)
+            .merge(Stream.never[IO])
+            .evalMap { value =>
+              IO.sleep(100.milliseconds) >> ref.set(value + 1) >> IO(value)
+            }
+            .take(2)
+        }
+        .flatMap(_.compile.toList)
+        .map(result => assert(result == expected))
     }
   }
 }