diff options
author | Alex Crichton <alex@alexcrichton.com> | 2017-08-24 08:16:04 -0700 |
---|---|---|
committer | Alex Crichton <alex@alexcrichton.com> | 2017-08-24 08:16:04 -0700 |
commit | e8617ea1fc0bbe8d06b785d8ce68aa2663ede2d7 (patch) | |
tree | 68cc274320b731faa001c99dff89deb0f4e33cd6 /examples/chat.rs | |
parent | 77d9a1aa4f536bbf7aa0217cc779be9508c2b7b4 (diff) |
Update futures dependency
Diffstat (limited to 'examples/chat.rs')
-rw-r--r-- | examples/chat.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/examples/chat.rs b/examples/chat.rs index 267e0aa6..0e05c8ad 100644 --- a/examples/chat.rs +++ b/examples/chat.rs @@ -68,7 +68,7 @@ fn main() { // Model the read portion of this socket by mapping an infinite // iterator to each line off the socket. This "loop" is then // terminated with an error once we hit EOF on the socket. - let iter = stream::iter(iter::repeat(()).map(Ok::<(), Error>)); + let iter = stream::iter_ok::<_, Error>(iter::repeat(())); let socket_reader = iter.fold(reader, move |reader, _| { // Read a line off the socket, failing if we're at EOF let line = io::read_until(reader, b'\n', Vec::new()); @@ -96,11 +96,11 @@ fn main() { .filter(|&(&k, _)| k != addr) .map(|(_, v)| v); for tx in iter { - tx.send(format!("{}: {}", addr, msg)).unwrap(); + tx.unbounded_send(format!("{}: {}", addr, msg)).unwrap(); } } else { let tx = conns.get_mut(&addr).unwrap(); - tx.send("You didn't send valid UTF-8.".to_string()).unwrap(); + tx.unbounded_send("You didn't send valid UTF-8.".to_string()).unwrap(); } reader }) |