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 9b75ab4 commit 0a912a2Copy full SHA for 0a912a2
io/jvm-native/src/main/scala/fs2/io/net/SocketPlatform.scala
@@ -117,10 +117,7 @@ private[net] trait SocketCompanionPlatform {
117
null,
118
new IntCompletionHandler(cb)
119
)
120
- F.delay(Some(F.delay {
121
- ch.shutdownInput()
122
- ()
123
- }))
+ F.delay(Some(endOfInput.voidError))
124
}
125
126
def write(bytes: Chunk[Byte]): F[Unit] = {
@@ -131,10 +128,7 @@ private[net] trait SocketCompanionPlatform {
131
128
132
129
133
130
134
135
- ch.shutdownOutput()
136
137
+ F.delay(Some(endOfOutput.voidError))
138
}.flatMap { written =>
139
if (written >= 0 && buff.remaining() > 0)
140
go(buff)
0 commit comments