eater/async-std
1
0
Fork 0
forked from mirror/async-std
Code Issues Pull requests Releases Wiki Activity

always call shutdown

Browse source
This commit is contained in:
dignifiedquire 2020-04-08 18:53:18 +02:00
parent 56769d8b6c
commit 1e99e3453f
2 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/net/tcp/stream.rs
View file

@ -343,6 +343,7 @@ impl Write for TcpStream {
} }
fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
self.shutdown(std::net::Shutdown::Write)?;
Pin::new(&mut &*self).poll_close(cx) Pin::new(&mut &*self).poll_close(cx)
} }
} }

1
src/os/unix/net/stream.rs
View file

@ -192,6 +192,7 @@ impl Write for UnixStream {
} }
fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
self.shutdown(std::net::Shutdown::Write)?;
Pin::new(&mut &*self).poll_close(cx) Pin::new(&mut &*self).poll_close(cx)
} }
} }