tuple fix

Angel-O · Angel-O · commit 5ba5055f4847 · 2023-03-16T00:07:50.000Z
diff --git a/core/shared/src/main/scala/fs2/Stream.scala b/core/shared/src/main/scala/fs2/Stream.scala
@@ -1563,7 +1563,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
               flushSize = a.min(groupSize) // apply cap (producer is still running)
             } yield (flushSize, flushSize - 1) // decrement permits (one already acquired)
 
-            F.ifM(supply.tryAcquireN(groupSize))(F.pure(groupSize, groupSize), nextChunk)
+            F.ifM(supply.tryAcquireN(groupSize))(F.pure((groupSize, groupSize)), nextChunk)
           }
 
           def emitChunk(n: Long): F2[Chunk[O]] = state.modify(_.splitAt(n))

Original file line number	Diff line number	Diff line change
`@@ -1563,7 +1563,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,`
`1563`	`1563`	`flushSize = a.min(groupSize) // apply cap (producer is still running)`
`1564`	`1564`	`} yield (flushSize, flushSize - 1) // decrement permits (one already acquired)`
`1565`	`1565`
`1566`		`- F.ifM(supply.tryAcquireN(groupSize))(F.pure(groupSize, groupSize), nextChunk)`
	`1566`	`+ F.ifM(supply.tryAcquireN(groupSize))(F.pure((groupSize, groupSize)), nextChunk)`
`1567`	`1567`	`}`
`1568`	`1568`
`1569`	`1569`	`def emitChunk(n: Long): F2[Chunk[O]] = state.modify(_.splitAt(n))`