We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c6d1146 commit 279f33cCopy full SHA for 279f33c
io/jvm/src/main/scala/fs2/io/net/unixsocket/UnixSocketsPlatform.scala
@@ -107,13 +107,11 @@ private[unixsocket] trait UnixSocketsCompanionPlatform {
107
108
def write(bytes: Chunk[Byte]): F[Unit] = {
109
def go(buff: ByteBuffer): F[Unit] =
110
- evalOnVirtualThreadIfAvailable(
111
- F.blocking(ch.write(buff)).cancelable(close) *>
112
- F.delay(buff.remaining <= 0).ifM(F.unit, go(buff))
113
- )
+ F.blocking(ch.write(buff)).cancelable(close) *>
+ F.delay(buff.remaining <= 0).ifM(F.unit, go(buff))
114
115
writeMutex.lock.surround {
116
- F.delay(bytes.toByteBuffer).flatMap(go)
+ F.delay(bytes.toByteBuffer).flatMap(buffer => evalOnVirtualThreadIfAvailable(go(buffer)))
117
}
118
119
0 commit comments