Skip to content

Commit df9c4f1

Browse files
author
Ankit Kumar
committed
removed cede because it was unnecessary
1 parent 77d1983 commit df9c4f1

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
@@ -2048,7 +2048,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
20482048

20492049
(Stream.exec(guard.acquire) ++ s.chunks
20502050
.filter(_.nonEmpty)
2051-
.evalMap(chk => F.cede >> sendChunk(chk)))
2051+
.evalMap(sendChunk))
20522052
// Stop when the other upstream has errored or the downstream has completed.
20532053
// This may also interrupt the initial call to `guard.acquire` as the call is made at the
20542054
// beginning of the stream.

0 commit comments

Comments
 (0)