File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
io/jvm/src/main/scala/fs2/io/net/unixsocket Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ private[unixsocket] class JdkUnixSocketsImpl[F[_]: Files](implicit F: Async[F])
4646 Resource
4747 .make(
4848 F .blocking(SocketChannel .open(StandardProtocolFamily .UNIX ))
49- )(ch => evalOnVirtualThreadIfAvailable( F .blocking(ch.close() )))
49+ )(ch => F .blocking(ch.close()))
5050 .evalTap { ch =>
5151 F .blocking(ch.connect(UnixDomainSocketAddress .of(address.path)))
5252 .cancelable(F .blocking(ch.close()))
@@ -61,7 +61,7 @@ private[unixsocket] class JdkUnixSocketsImpl[F[_]: Files](implicit F: Async[F])
6161 )(ch => F .blocking(ch.close()))
6262 .evalTap { sch =>
6363 F .blocking(sch.bind(UnixDomainSocketAddress .of(address.path)))
64- .cancelable(evalOnVirtualThreadIfAvailable( F .blocking(sch.close() )))
64+ .cancelable(F .blocking(sch.close()))
6565 }
6666 .map { sch =>
6767 Resource .makeFull[F , SocketChannel ] { poll =>
You can’t perform that action at this time.
0 commit comments