---

yaml
---
r: 14299
b: refs/heads/try
c: b157f0b
h: refs/heads/master
i:
  14297: 1cda0f3
  14295: cc050bf
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: a53a08e1b980e5cf5f9707ef1d1f27b89ff7ed99
+refs/heads/try: b157f0b263fba5a1c7e8e80a744f6f22ff3c7276
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/try/src/libcore/comm.rs

@@ -26,6 +26,7 @@ import task;
 
 export send;
 export recv;
+export peek;
 export chan::{};
 export port::{};
 
@@ -153,6 +154,11 @@ fn recv_<T: send>(p: *rust_port) -> T {
     ret res;
 }
 
+#[doc = "Returns true if there are messages available"]
+fn peek<T: send>(p: port<T>) -> bool {
+    rustrt::rust_port_size(***p) != 0u as ctypes::size_t
+}
+
 #[doc(
   brief = "Constructs a channel. The channel is bound to the \
            port used to construct it."
@@ -203,3 +209,13 @@ fn chan_chan() {
     recv(p);
 }
 
+#[test]
+fn test_peek() {
+    let po = port();
+    let ch = chan(po);
+    assert !peek(po);
+    send(ch, ());
+    assert peek(po);
+    recv(po);
+    assert !peek(po);
+}