summaryrefslogtreecommitdiffstats
path: root/tokio/src/net/tcp/split.rs
diff options
context:
space:
mode:
authorSean McArthur <sean@seanmonstar.com>2019-12-13 10:25:27 -0800
committerGitHub <noreply@github.com>2019-12-13 10:25:27 -0800
commit8abaf89e5f3d3371f600777751741a3bb0a1047a (patch)
treec7e0f18ddfa8bcc0a69042d2bf37cecaa06f5aac /tokio/src/net/tcp/split.rs
parentb560df9e669f73d4663915d9e6dd17af9ab227b9 (diff)
Re-enable writev support in TcpStreams (#1956)
Diffstat (limited to 'tokio/src/net/tcp/split.rs')
-rw-r--r--tokio/src/net/tcp/split.rs9
1 files changed, 9 insertions, 0 deletions
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<B: Buf>(
+ self: Pin<&mut Self>,
+ cx: &mut Context<'_>,
+ buf: &mut B,
+ ) -> Poll<io::Result<usize>> {
+ self.0.poll_write_buf_priv(cx, buf)
+ }
+
#[inline]
fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<()>> {
// tcp flush is a no-op