From 8abaf89e5f3d3371f600777751741a3bb0a1047a Mon Sep 17 00:00:00 2001 From: Sean McArthur Date: Fri, 13 Dec 2019 10:25:27 -0800 Subject: Re-enable writev support in TcpStreams (#1956) --- tokio/src/net/tcp/split.rs | 9 +++++++++ 1 file changed, 9 insertions(+) (limited to 'tokio/src/net/tcp/split.rs') diff --git a/tokio/src/net/tcp/split.rs b/tokio/src/net/tcp/split.rs index 2b337c08..6034d4ef 100644 --- a/tokio/src/net/tcp/split.rs +++ b/tokio/src/net/tcp/split.rs @@ -11,6 +11,7 @@ use crate::io::{AsyncRead, AsyncWrite}; use crate::net::TcpStream; +use bytes::Buf; use std::io; use std::mem::MaybeUninit; use std::net::Shutdown; @@ -55,6 +56,14 @@ impl AsyncWrite for WriteHalf<'_> { self.0.poll_write_priv(cx, buf) } + fn poll_write_buf( + self: Pin<&mut Self>, + cx: &mut Context<'_>, + buf: &mut B, + ) -> Poll> { + self.0.poll_write_buf_priv(cx, buf) + } + #[inline] fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll> { // tcp flush is a no-op -- cgit v1.2.3