From 138e50159945b55774e3d3486e9c130758d94b0d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Thu, 14 May 2020 01:06:18 +0200 Subject: [PATCH] aquatic_ws: impl read_vectored and write_vectored for Stream --- aquatic_ws/src/lib/network/common.rs | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/aquatic_ws/src/lib/network/common.rs b/aquatic_ws/src/lib/network/common.rs index cc198fa..e18458e 100644 --- a/aquatic_ws/src/lib/network/common.rs +++ b/aquatic_ws/src/lib/network/common.rs @@ -55,6 +55,18 @@ impl Read for Stream { Self::TlsStream(stream) => stream.read(buf), } } + + /// Not used but provided for completeness + #[inline] + fn read_vectored( + &mut self, + bufs: &mut [::std::io::IoSliceMut<'_>] + ) -> ::std::io::Result { + match self { + Self::TcpStream(stream) => stream.read_vectored(bufs), + Self::TlsStream(stream) => stream.read_vectored(bufs), + } + } } @@ -67,6 +79,18 @@ impl Write for Stream { } } + /// Not used but provided for completeness + #[inline] + fn write_vectored( + &mut self, + bufs: &[::std::io::IoSlice<'_>] + ) -> ::std::io::Result { + match self { + Self::TcpStream(stream) => stream.write_vectored(bufs), + Self::TlsStream(stream) => stream.write_vectored(bufs), + } + } + #[inline] fn flush(&mut self) -> ::std::io::Result<()> { match self {