---

yaml
---
r: 23111
b: refs/heads/master
c: 6a10e3a
h: refs/heads/master
i:
  23109: c4d2401
  23107: 3e9df2b
  23103: ab9e21c
v: v3

Author: eholk

[refs]

@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 812db1ec0d97217414b4e49962e8da75761b9279
+refs/heads/master: 6a10e3a71324cddce3e4dcb21f1b43dcdec89775
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: cd6f24f9d14ac90d167386a56e7a6ac1f0318195
 refs/heads/try: ffbe0e0e00374358b789b0037bcb3a577cd218be

trunk/src/libcore/pipes.rs

@@ -76,6 +76,7 @@ export send_packet, recv_packet, send, recv, try_recv, peek;
 export select, select2, selecti, select2i, selectable;
 export spawn_service, spawn_service_recv;
 export stream, port, chan, shared_chan, port_set, channel;
+export oneshot, recv_one, try_recv_one;
 
 #[doc(hidden)]
 const SPIN_COUNT: uint = 0;
@@ -1103,6 +1104,32 @@ impl<T: send, U: send, Left: selectable recv<T>, Right: selectable recv<U>>
     }
 }
 
+proto! oneshot {
+    oneshot:send<T:send> {
+        send(T) -> !
+    }
+}
+
+/// Receive a message from a oneshot pipe.
+fn recv_one<T: send>(+port: oneshot::server::oneshot<T>) -> T {
+    let oneshot::send(message) = recv(port);
+    message
+}
+
+/** Receive a message from a oneshot pipe, or fail if the connection
+is closed.
+
+*/
+fn try_recv_one<T: send> (+port: oneshot::server::oneshot<T>) -> option<T> {
+    let message = try_recv(port);
+
+    if message == none { none }
+    else {
+        let oneshot::send(message) = option::unwrap(message);
+        some(message)
+    }
+}
+
 #[cfg(test)]
 mod test {
     #[test]
@@ -1119,4 +1146,13 @@ mod test {
 
         c2.send(123);
     }
+
+    #[test]
+    fn test_oneshot() {
+        let (c, p) = oneshot::init();
+
+        oneshot::client::send(c, ());
+
+        recv_one(p)
+    }
 }