diff options
author | bors-servo <metajack+bors@gmail.com> | 2014-11-17 07:57:29 -0700 |
---|---|---|
committer | bors-servo <metajack+bors@gmail.com> | 2014-11-17 07:57:29 -0700 |
commit | 9833cfbbffa79c74d9ee794e836c8007cd802c10 (patch) | |
tree | b2a7c00eb4e56a9bd1f05ac918eac241f6a8ad01 | |
parent | b9dcaa34c32333ae16da7a5f11835c7d905da4d3 (diff) | |
parent | d8b0f973b0dea54736b1d3d4bb13494f9a605ee7 (diff) | |
download | servo-9833cfbbffa79c74d9ee794e836c8007cd802c10.tar.gz servo-9833cfbbffa79c74d9ee794e836c8007cd802c10.zip |
auto merge of #4017 : Ms2ger/servo/sniffertask, r=jdm
-rw-r--r-- | components/net/sniffer_task.rs | 39 |
1 files changed, 18 insertions, 21 deletions
diff --git a/components/net/sniffer_task.rs b/components/net/sniffer_task.rs index a39e6fc2beb..9df39e59a51 100644 --- a/components/net/sniffer_task.rs +++ b/components/net/sniffer_task.rs @@ -10,37 +10,34 @@ use resource_task::{LoadResponse}; pub type SnifferTask = Sender<LoadResponse>; pub fn new_sniffer_task(next_rx: Sender<LoadResponse>) -> SnifferTask { - let(sen, rec) = channel(); - let builder = TaskBuilder::new().named("SnifferManager"); - builder.spawn(proc(){ - SnifferManager::new(rec).start(next_rx); - }); - sen + let (sen, rec) = channel(); + let builder = TaskBuilder::new().named("SnifferManager"); + builder.spawn(proc() { + SnifferManager::new(rec).start(next_rx); + }); + sen } struct SnifferManager { - data_receiver: Receiver<LoadResponse>, + data_receiver: Receiver<LoadResponse>, } impl SnifferManager { - fn new(data_receiver: Receiver <LoadResponse>) -> SnifferManager { - SnifferManager { - data_receiver: data_receiver, + fn new(data_receiver: Receiver<LoadResponse>) -> SnifferManager { + SnifferManager { + data_receiver: data_receiver, + } } - } } impl SnifferManager { - fn start(&self, next_rx: Sender<LoadResponse>) { - loop { - match self.data_receiver.try_recv() { - Ok(snif_data) => next_rx.send(snif_data), - Err(e) => { - if e == Disconnected { - break - } + fn start(&self, next_rx: Sender<LoadResponse>) { + loop { + match self.data_receiver.try_recv() { + Ok(snif_data) => next_rx.send(snif_data), + Err(Disconnected) => break, + Err(_) => (), + } } - } } - } } |