Use a proper protocol definition instead of the already-expanded code.

This commit is contained in:
Eric Holk 2012-08-06 14:34:53 -07:00
parent 18ac4a8e6d
commit d594f3701a

View file

@ -1,22 +1,6 @@
// Generated from pipe compiler
mod stream {
fn init<T: send>() -> (client::stream<T>, server::stream<T>) {
pipes::entangle()
}
enum stream<T: send> { send(T, server::stream<T>), }
mod client {
fn send<T: send>(+pipe: stream<T>, +x_0: T) -> stream<T> {
{
let (c, s) = pipes::entangle();
let message = stream::send(x_0, s);
pipes::send(pipe, message);
c
}
}
type stream<T: send> = pipes::send_packet<stream::stream<T>>;
}
mod server {
type stream<T: send> = pipes::recv_packet<stream::stream<T>>;
proto! stream {
stream:send<T:send> {
send(T) -> stream<T>
}
}