itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-09-28 12:10:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix connect example

Browse Source
This commit is contained in:
Alex Crichton 2016-12-20 18:39:44 -08:00
parent 99078c5cc1
commit 717e99ca80
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/connect.rs
View File

@ -59,7 +59,7 @@ fn main() {
// finishes. If we don't have any more data to read or we won't receive any // finishes. If we don't have any more data to read or we won't receive any
// more work from the remote then we can exit. // more work from the remote then we can exit.
let mut stdout = io::stdout(); let mut stdout = io::stdout();
let client = tcp.and_then(|(sink, stream)| { let client = tcp.and_then(|stream| {
let (sink, stream) = stream.framed(Bytes).split(); let (sink, stream) = stream.framed(Bytes).split();
let send_stdin = stdin_rx.forward(sink); let send_stdin = stdin_rx.forward(sink);
let write_stdout = stream.for_each(move |buf| { let write_stdout = stream.for_each(move |buf| {