diff options
Diffstat (limited to 'src/servo/util/task.rs')
| -rw-r--r-- | src/servo/util/task.rs | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/servo/util/task.rs b/src/servo/util/task.rs index 11fb6a2e38a..d133fc1ee14 100644 --- a/src/servo/util/task.rs +++ b/src/servo/util/task.rs @@ -1,12 +1,11 @@ -use core::pipes::{Chan, Port}; -use core::pipes; +use core::comm::{Chan, Port}; use core::task; use std::cell::Cell; pub fn spawn_listener<A: Owned>(f: fn~(Port<A>)) -> Chan<A> { - let (setup_po, setup_ch) = pipes::stream(); + let (setup_po, setup_ch) = comm::stream(); do task::spawn { - let (po, ch) = pipes::stream(); + let (po, ch) = comm::stream(); setup_ch.send(ch); f(po); } @@ -14,7 +13,7 @@ pub fn spawn_listener<A: Owned>(f: fn~(Port<A>)) -> Chan<A> { } pub fn spawn_conversation<A: Owned, B: Owned>(f: fn~(Port<A>, Chan<B>)) -> (Port<B>, Chan<A>) { - let (from_child, to_parent) = pipes::stream(); + let (from_child, to_parent) = comm::stream(); let to_parent = Cell(to_parent); let to_child = do spawn_listener |from_parent| { f(from_parent, to_parent.take()) |