summaryrefslogtreecommitdiffstats
path: root/tokio/tests/io_write_all.rs
diff options
context:
space:
mode:
authorLucio Franco <luciofranco14@gmail.com>2019-08-02 15:23:44 -0400
committerCarl Lerche <me@carllerche.com>2019-08-02 12:23:44 -0700
commitff41108834ab8fdf92e5c337b46637ba696d89c7 (patch)
treeb11dd84a9443281b03432a68a016be813f58017a /tokio/tests/io_write_all.rs
parent6b202722ea78548b941b3aa6e92ff281a7ce42c5 (diff)
io: move io helpers back into `tokio-io` (#1377)
Utilities are made optional with a feature flag.
Diffstat (limited to 'tokio/tests/io_write_all.rs')
-rw-r--r--tokio/tests/io_write_all.rs51
1 files changed, 0 insertions, 51 deletions
diff --git a/tokio/tests/io_write_all.rs b/tokio/tests/io_write_all.rs
deleted file mode 100644
index b12e0f81..00000000
--- a/tokio/tests/io_write_all.rs
+++ /dev/null
@@ -1,51 +0,0 @@
-#![deny(warnings, rust_2018_idioms)]
-#![feature(async_await)]
-
-use tokio::io::{AsyncWrite, AsyncWriteExt};
-use tokio_test::assert_ok;
-
-use bytes::BytesMut;
-use std::cmp;
-use std::io;
-use std::pin::Pin;
-use std::task::{Context, Poll};
-
-#[tokio::test]
-async fn write_all() {
- struct Wr {
- buf: BytesMut,
- cnt: usize,
- }
-
- impl AsyncWrite for Wr {
- fn poll_write(
- mut self: Pin<&mut Self>,
- _cx: &mut Context<'_>,
- buf: &[u8],
- ) -> Poll<io::Result<usize>> {
- let n = cmp::min(4, buf.len());
- let buf = &buf[0..n];
-
- self.cnt += 1;
- self.buf.extend(buf);
- Ok(buf.len()).into()
- }
-
- fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> {
- Ok(()).into()
- }
-
- fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> {
- Ok(()).into()
- }
- }
-
- let mut wr = Wr {
- buf: BytesMut::with_capacity(64),
- cnt: 0,
- };
-
- assert_ok!(wr.write_all(b"hello world").await);
- assert_eq!(wr.buf, b"hello world"[..]);
- assert_eq!(wr.cnt, 3);
-}