test(body): remove concat test for Body
This commit is contained in:
@@ -38,7 +38,6 @@ pin-utils = "0.1.0-alpha.4"
|
|||||||
time = "0.1"
|
time = "0.1"
|
||||||
tokio = { git = "https://github.com/tokio-rs/tokio", optional = true, default-features = false, features = ["rt-full"] }
|
tokio = { git = "https://github.com/tokio-rs/tokio", optional = true, default-features = false, features = ["rt-full"] }
|
||||||
tokio-buf = "0.1"
|
tokio-buf = "0.1"
|
||||||
tokio-current-thread = { git = "https://github.com/tokio-rs/tokio" }
|
|
||||||
tokio-executor = { 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-io = { git = "https://github.com/tokio-rs/tokio" }
|
||||||
tokio-reactor = { git = "https://github.com/tokio-rs/tokio", optional = true }
|
tokio-reactor = { git = "https://github.com/tokio-rs/tokio", optional = true }
|
||||||
|
|||||||
@@ -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");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user