core: Add comm::listen

src/libcore/comm.rs

@@ -34,6 +34,7 @@ export peek;
 export recv_chan;
 export select2;
 export methods;
+export listen;
 
 
 #[doc = "
@@ -86,6 +87,12 @@ impl methods<T: send> for chan<T> {
 
 }
 
+#[doc = "Open a new receiving channel for the duration of a function"]
+fn listen<T: send, U>(f: fn(chan<T>) -> U) -> U {
+    let po = port();
+    f(po.chan())
+}
+
 resource port_ptr<T: send>(po: *rust_port) {
     // Once the port is detached it's guaranteed not to receive further
     // messages
@@ -442,3 +449,13 @@ fn test_chan_peek() {
     ch.send(());
     assert ch.peek();
 }
+
+#[test]
+fn test_listen() {
+    listen {|parent|
+        task::spawn {||
+            parent.send("oatmeal-salad");
+        }
+        assert parent.recv() == "oatmeal-salad";
+    }
+}