gistfile1.txt

extern mod std;
use core::pipes::*;
use std::comm::DuplexStream;
use core::task;

fn main () {
    let (chan, port): (Chan<int>, Port<int>) = stream();

    do task::spawn() |move port| {
        assert port.recv() == 123;
        assert !port.peek();
    }

    chan.send(123);
}