---

yaml
---
r: 4463
b: refs/heads/master
c: 86babab
h: refs/heads/master
i:
  4461: e5e6333
  4459: b172142
  4455: 3be4011
  4447: edc5b32
v: v3

Author: Eric Holk

[refs]

@@ -1,2 +1,2 @@
 ---
-refs/heads/master: 0aeddb3673459969fdbb32018f9c59f603607cf5
+refs/heads/master: 86babab2fe92223511042e9cb4b233841cffa054

trunk/src/lib/comm.rs

@@ -6,14 +6,15 @@ export _chan;
 export _port;
 
 export mk_port;
+export chan_from_unsafe_ptr;
 
 native "rust" mod rustrt {
     type void;
     type rust_chan;
     type rust_port;
 
     fn new_chan(po : *rust_port) -> *rust_chan;
-    fn del_chan(ch : *rust_chan);
+    fn take_chan(ch : *rust_chan);
     fn drop_chan(ch : *rust_chan);
     fn chan_send(ch: *rust_chan, v : *void);
 
@@ -42,6 +43,16 @@ obj _chan[T](raw_chan : @chan_ptr) {
         rustrt::chan_send(**raw_chan,
                           unsafe::reinterpret_cast(ptr::addr_of(v)));
     }
+
+    // Use this to get something we can send over a channel.
+    fn unsafe_ptr() -> *u8 {
+        rustrt::take_chan(**raw_chan);
+        ret unsafe::reinterpret_cast(**raw_chan);
+    }
+}
+
+fn chan_from_unsafe_ptr[T](ch : *u8) -> _chan[T] {
+    _chan(@chan_ptr(unsafe::reinterpret_cast(ch)))
 }
 
 obj _port[T](raw_port : @port_ptr) {

trunk/src/test/run-pass/task-comm-0.rs

@@ -1,14 +1,23 @@
+use std;
+
+import std::comm;
+
 fn main() { test05(); }
 
-fn test05_start(ch: chan[int]) { ch <| 10; ch <| 20; ch <| 30; }
+fn test05_start(pch: *u8) {
+    let ch = comm::chan_from_unsafe_ptr(pch);
+
+    ch.send(10);
+    ch.send(20);
+    ch.send(30);
+}
 
 fn test05() {
-    let po: port[int] = port();
-    let ch: chan[int] = chan(po);
-    spawn test05_start(chan(po));
-    let value: int;
-    po |> value;
-    po |> value;
-    po |> value;
+    let po = comm::mk_port[int]();
+    let ch = po.mk_chan();
+    spawn test05_start(ch.unsafe_ptr());
+    let value = po.recv();
+    value = po.recv();
+    value = po.recv();
     assert (value == 30);
 }