Update io/jvm/src/main/scala/fs2/io/net/SelectingSocket.scala

rahulrangers · armanbilge · web-flow · commit 89952122b154 · 2025-04-02T00:24:32.000+05:30
Co-authored-by: Arman Bilge &lt;armanbilge@gmail.com&gt;
diff --git a/io/jvm/src/main/scala/fs2/io/net/SelectingSocket.scala b/io/jvm/src/main/scala/fs2/io/net/SelectingSocket.scala
@@ -100,7 +100,7 @@ private final class SelectingSocket[F[_]: LiftIO] private (
           }
         }
 
-      Stream.eval(writeMutex.lock.surround(go(offset, count))).drain
+      Stream.exec(writeMutex.lock.surround(go(offset, count)))
 
     case _ =>
       super.sendFile(file, offset, count, chunkSize)

Original file line number	Diff line number	Diff line change
`@@ -100,7 +100,7 @@ private final class SelectingSocket[F[_]: LiftIO] private (`
`100`	`100`	`}`
`101`	`101`	`}`
`102`	`102`
`103`		`- Stream.eval(writeMutex.lock.surround(go(offset, count))).drain`
	`103`	`+ Stream.exec(writeMutex.lock.surround(go(offset, count)))`
`104`	`104`
`105`	`105`	`case _ =>`
`106`	`106`	`super.sendFile(file, offset, count, chunkSize)`