---

yaml
---
r: 27671
b: refs/heads/try
c: c0874db
h: refs/heads/master
i:
  27669: 20fddac
  27667: 17a8926
  27663: 13e6784
v: v3

Author: eholk

[refs]

@@ -2,7 +2,7 @@
 refs/heads/master: cd6f24f9d14ac90d167386a56e7a6ac1f0318195
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: cd6f24f9d14ac90d167386a56e7a6ac1f0318195
-refs/heads/try: 1beb1f491fdd2d05ca2c05edc966535064c98cf4
+refs/heads/try: c0874dbd21c89854c68e8db7201f5557ab5e6259
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
 refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
 refs/heads/try2: d0c6ce338884ee21843f4b40bf6bf18d222ce5df

branches/try/src/libcore/pipes.rs

@@ -877,6 +877,9 @@ trait channel<T: send> {
 
     /// Sends a message.
     fn send(+x: T);
+
+    /// Sends a message, or report if the receiver has closed the connection.
+    fn try_send(+x: T) -> bool;
 }
 
 /// A trait for things that can receive multiple messages.
@@ -931,6 +934,18 @@ impl chan<T: send> of channel<T> for chan<T> {
         self.endp = some(
             streamp::client::data(unwrap(endp), x))
     }
+
+    fn try_send(+x: T) -> bool {
+        let mut endp = none;
+        endp <-> self.endp;
+        match move streamp::client::try_data(unwrap(endp), x) {
+            some(next) => {
+                self.endp = some(move_it!(next));
+                true
+            }
+            none => false
+        }
+    }
 }
 
 impl port<T: send> of recv<T> for port<T> {
@@ -1047,6 +1062,15 @@ impl chan<T: send> of channel<T> for shared_chan<T> {
             chan.send(option::unwrap(x))
         }
     }
+
+    fn try_send(+x: T) -> bool {
+        let mut xx = some(x);
+        do self.with |chan| {
+            let mut x = none;
+            x <-> xx;
+            chan.try_send(option::unwrap(x))
+        }
+    }
 }
 
 /// Converts a `chan` into a `shared_chan`.