Partially revert "Merge pull request typelevel#2644 from stephennance…

…kivell/fix/typelevelGH-2643-socket-leak" This partially reverts commit 271f8b8, reversing changes made to f92941b.
armanbilge · Oct 5, 2021 · fc3872a · fc3872a
1 parent b2a90a1
commit fc3872a
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]