Set client socket options on JVM Unix

Author: mpilquist

io/jvm-native/src/main/scala/fs2/io/net/SocketOptionPlatform.scala

@@ -97,4 +97,6 @@ private[net] trait SocketOptionCompanionPlatform {
   }
   def unixServerSocketDeleteOnClose(value: Boolean): SocketOption =
     boolean(UnixServerSocketDeleteOnClose, value)
+
+  // TODO SO_PEERCRED
 }

io/jvm/src/main/scala/fs2/io/net/JdkUnixSocketsProvider.scala

@@ -23,6 +23,7 @@ package fs2
 package io
 package net
 
+import cats.syntax.all._
 import cats.effect.{Async, Resource}
 import cats.effect.syntax.all._
 
@@ -46,15 +47,16 @@ private[net] object JdkUnixSocketsProvider {
 
 private[net] class JdkUnixSocketsProvider[F[_]: Files](implicit F: Async[F])
     extends UnixSocketsProvider.AsyncUnixSocketsProvider[F] {
-  protected def openChannel(address: UnixSocketAddress) =
+  protected def openChannel(address: UnixSocketAddress, options: List[SocketOption]) =
     evalOnVirtualThreadIfAvailable(
       Resource
         .make(
           F.blocking(SocketChannel.open(StandardProtocolFamily.UNIX))
         )(ch => F.blocking(ch.close()))
         .evalTap { ch =>
           F.blocking(ch.connect(UnixDomainSocketAddress.of(address.path)))
-            .cancelable(F.blocking(ch.close()))
+            .cancelable(F.blocking(ch.close())) *>
+            F.delay(options.foreach(o => ch.setOption(o.key, o.value)))
         }
     )
 

io/jvm/src/main/scala/fs2/io/net/JnrUnixSocketsProvider.scala

@@ -57,10 +57,12 @@ private[net] object JnrUnixSocketsProvider {
 private[net] class JnrUnixSocketsProvider[F[_]](implicit F: Async[F], F2: Files[F])
     extends UnixSocketsProvider.AsyncUnixSocketsProvider[F] {
 
-  protected def openChannel(address: UnixSocketAddress) =
-    Resource.make(F.blocking(UnixSocketChannel.open(new JnrUnixSocketAddress(address.path))))(ch =>
-      F.blocking(ch.close())
-    )
+  protected def openChannel(address: UnixSocketAddress, options: List[SocketOption]) =
+    Resource
+      .make(F.blocking(UnixSocketChannel.open(new JnrUnixSocketAddress(address.path))))(ch =>
+        F.blocking(ch.close())
+      )
+      .evalTap(ch => F.delay(options.foreach(o => ch.setOption(o.key, o.value))))
 
   protected def openServerChannel(address: UnixSocketAddress, options: List[SocketOption]) =
     Resource

io/jvm/src/main/scala/fs2/io/net/UnixSocketsProviderPlatform.scala

@@ -57,15 +57,18 @@ private[net] trait UnixSocketsProviderCompanionPlatform {
   abstract class AsyncUnixSocketsProvider[F[_]: Files](implicit F: Async[F])
       extends UnixSocketsProvider[F] {
 
-    protected def openChannel(address: UnixSocketAddress): Resource[F, SocketChannel]
+    protected def openChannel(
+        address: UnixSocketAddress,
+        options: List[SocketOption]
+    ): Resource[F, SocketChannel]
 
     protected def openServerChannel(
         address: UnixSocketAddress,
         options: List[SocketOption]
     ): Resource[F, (SocketInfo[F], Resource[F, SocketChannel])]
 
     def connect(address: UnixSocketAddress, options: List[SocketOption]): Resource[F, Socket[F]] =
-      openChannel(address).evalMap(makeSocket[F](_, UnixSocketAddress(""), address))
+      openChannel(address, options).evalMap(makeSocket[F](_, UnixSocketAddress(""), address))
 
     def bind(
         address: UnixSocketAddress,