---

yaml
---
r: 29778
b: refs/heads/incoming
c: 2ac2883
h: refs/heads/master
v: v3

Author: bblum

[refs]

@@ -6,7 +6,7 @@ refs/heads/try: d324a424d8f84b1eb049b12cf34182bda91b0024
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
 refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
 refs/heads/try2: d0c6ce338884ee21843f4b40bf6bf18d222ce5df
-refs/heads/incoming: 4ec1dd991405404725b5cc448295dc0be9cd17e5
+refs/heads/incoming: 2ac288383d22e8c4a18561293cfddd64a48e7b38
 refs/heads/dist-snap: 2f32a1581f522e524009138b33b1c7049ced668d
 refs/tags/release-0.2: c870d2dffb391e14efb05aa27898f1f6333a9596
 refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503

branches/incoming/src/libcore/pipes.rs

@@ -1144,16 +1144,22 @@ proto! oneshot {
     }
 }
 
-/// Receive a message from a oneshot pipe.
+/// Initialiase a (send-endpoint, recv-endpoint) oneshot pipe pair.
+fn oneshot<T: send>() -> (oneshot::client::oneshot<T>,
+                          oneshot::server::oneshot<T>) {
+    oneshot::init()
+}
+
+/**
+ * Receive a message from a oneshot pipe, failing if the connection was
+ * closed.
+ */
 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.
-
-*/
+/// Receive a message from a oneshot pipe unless the connection was closed.
 fn try_recv_one<T: send> (+port: oneshot::server::oneshot<T>) -> option<T> {
     let message = try_recv(port);
 
@@ -1164,6 +1170,20 @@ fn try_recv_one<T: send> (+port: oneshot::server::oneshot<T>) -> option<T> {
     }
 }
 
+/// Send a message on a oneshot pipe, failing if the connection was closed.
+fn send_one<T: send>(+chan: oneshot::client::oneshot<T>, +data: T) {
+    oneshot::client::send(chan, data);
+}
+
+/**
+ * Send a message on a oneshot pipe, or return false if the connection was
+ * closed.
+ */
+fn try_send_one<T: send>(+chan: oneshot::client::oneshot<T>, +data: T)
+        -> bool {
+    oneshot::client::try_send(chan, data).is_some()
+}
+
 #[cfg(test)]
 mod test {
     #[test]