Merge pull request #2665 from armanbilge/fix/socket-close

Fix socket close regression
typelevel · Oct 6, 2021 · 6149851 · 6149851
2 parents e345809 + fc3872a
commit 6149851
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/io/jvm/src/main/scala/fs2/io/net/SocketPlatform.scala b/io/jvm/src/main/scala/fs2/io/net/SocketPlatform.scala
@@ -36,11 +36,11 @@ private[net] trait SocketCompanionPlatform {
   private[net] def forAsync[F[_]: Async](
       ch: AsynchronousSocketChannel
   ): Resource[F, Socket[F]] =
-    Resource.eval {
+    Resource.make {
       (Semaphore[F](1), Semaphore[F](1)).mapN { (readSemaphore, writeSemaphore) =>
         new AsyncSocket[F](ch, readSemaphore, writeSemaphore)
       }
-    }
+    }(_ => Async[F].delay(if (ch.isOpen) ch.close else ()))
 
   private[net] abstract class BufferedReads[F[_]](
       readSemaphore: Semaphore[F]