aboutsummaryrefslogtreecommitdiffstats
path: root/components/net/sniffer_task.rs
diff options
context:
space:
mode:
Diffstat (limited to 'components/net/sniffer_task.rs')
-rw-r--r--components/net/sniffer_task.rs12
1 files changed, 6 insertions, 6 deletions
diff --git a/components/net/sniffer_task.rs b/components/net/sniffer_task.rs
index 2fcc0394f52..2b9b2363a0a 100644
--- a/components/net/sniffer_task.rs
+++ b/components/net/sniffer_task.rs
@@ -3,16 +3,16 @@
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
//! A task that sniffs data
-use std::comm::{channel, Receiver, Sender};
-use std::task::TaskBuilder;
+use std::sync::mpsc::{channel, Receiver, Sender};
+use std::thread::Builder;
use resource_task::{TargetedLoadResponse};
pub type SnifferTask = Sender<TargetedLoadResponse>;
pub fn new_sniffer_task() -> SnifferTask {
let(sen, rec) = channel();
- let builder = TaskBuilder::new().named("SnifferManager");
- builder.spawn(proc() {
+ let builder = Builder::new().name("SnifferManager".to_string());
+ builder.spawn(move || {
SnifferManager::new(rec).start();
});
sen
@@ -33,9 +33,9 @@ impl SnifferManager {
impl SnifferManager {
fn start(self) {
loop {
- match self.data_receiver.recv_opt() {
+ match self.data_receiver.recv() {
Ok(snif_data) => {
- let _ = snif_data.consumer.send_opt(snif_data.load_response);
+ let _ = snif_data.consumer.send(snif_data.load_response);
}
Err(_) => break,
}