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

Merge remote-tracking branch 'core/master' into new-crate

Browse Source
This commit is contained in:
Carl Lerche 2017-11-06 23:30:10 -08:00
commit 9c16d47632
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
examples/tinyhttp.rs
View File

@ -62,9 +62,10 @@ fn main() {
}
let mut next = 0;
for socket in listener.incoming() {
let socket = socket.expect("failed to accept");
channels[next].unbounded_send(socket).expect("worker thread died");
next = (next + 1) % channels.len();
if let Ok(socket) = socket {
channels[next].unbounded_send(socket).expect("worker thread died");
next = (next + 1) % channels.len();
}
}
}