Skip to content

Commit 87bd84f

Browse files
Angel-Odiesalbla
andauthored
Update core/shared/src/main/scala/fs2/Stream.scala
Co-authored-by: Diego E. Alonso Blas <[email protected]>
1 parent 09a48b1 commit 87bd84f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/shared/src/main/scala/fs2/Stream.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1543,7 +1543,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
15431543
val groupSize = chunkSize.toLong
15441544

15451545
val enqueue: F2[Unit] =
1546-
evalTap(o => state.update(State.add[O](o)) *> supply.release)
1546+
foreach(o => state.update(State.add[O](o)) *> supply.release)
15471547
.covary[F2]
15481548
.compile
15491549
.drain

0 commit comments

Comments
 (0)