diff --git a/Cargo.toml b/Cargo.toml index cafc0fac..248d4a45 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -38,7 +38,6 @@ pin-utils = "0.1.0-alpha.4" time = "0.1" tokio = { git = "https://github.com/tokio-rs/tokio", optional = true, default-features = false, features = ["rt-full"] } tokio-buf = "0.1" -tokio-current-thread = { git = "https://github.com/tokio-rs/tokio" } tokio-executor = { git = "https://github.com/tokio-rs/tokio" } tokio-io = { git = "https://github.com/tokio-rs/tokio" } tokio-reactor = { git = "https://github.com/tokio-rs/tokio", optional = true } diff --git a/src/body/body.rs b/src/body/body.rs index d4e01155..388dccb4 100644 --- a/src/body/body.rs +++ b/src/body/body.rs @@ -547,22 +547,3 @@ impl Sink for Sender { } } */ - -#[cfg(test)] -mod tests { - // FIXME: re-implement tests with `async/await`, this import should - // trigger a warning to remind us - use crate::Error; - use futures_util::try_stream::TryStreamExt; - use tokio::runtime::current_thread::Runtime; - - use super::*; - #[test] - fn test_body_stream_concat() { - let body = Body::from("hello world"); - - let mut rt = Runtime::new().unwrap(); - let total = rt.block_on(body.try_concat()).unwrap(); - assert_eq!(total.as_ref(), b"hello world"); - } -}