fix chaining

This commit is contained in:
NikVolf 2017-03-15 04:08:22 +03:00
parent d247bb7840
commit e5670df3c5
1 changed files with 2 additions and 2 deletions

View File

@ -206,8 +206,8 @@ mod tests {
println!("Created connection");
let (reader, writer) = stream.split();
let mut buf = Vec::new();
io::read_to_end(reader, buf).and_then(move |(reader, buf)| io::write_all(writer, "Ok"));
future::ok(())
io::read_to_end(reader, buf).and_then(move |(reader, buf)| io::write_all(writer, "Ok"))
.map(|_| ())
})
.map(|_| ())
.map_err(|_e| ())