---

yaml
---
r: 15744
b: refs/heads/try
c: c6d33c3
h: refs/heads/master
v: v3

Author: brson

[refs]

@@ -2,5 +2,5 @@
 refs/heads/master: 61b1875c16de39c166b0f4d54bba19f9c6777d1a
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
-refs/heads/try: 13a4b59cc854d9c47d885bd1e468e094d53756b1
+refs/heads/try: c6d33c3d37c0e9f8db88b7402da45506d7f44d33
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/try/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
@@ -441,4 +448,14 @@ fn test_chan_peek() {
     let ch = po.chan();
     ch.send(());
     assert ch.peek();
+}
+
+#[test]
+fn test_listen() {
+    listen {|parent|
+        task::spawn {||
+            parent.send("oatmeal-salad");
+        }
+        assert parent.recv() == "oatmeal-salad";
+    }
 }