comm_event_loop.rs

use std::comm::{Port, Chan};

enum Event {
    Pos(int, int),
}

fn main() {
    let (port, chan) = Chan::new();
    spawn(proc() handle_events(port));
    run_event_loop(chan);
}

fn handle_events(port: Port<Event>) {
    let mut curr_x: int;
    let mut curr_y: int;
    for x in port.iter() {
        match x {
            Pos(x, y) => {
                curr_x = x;
                curr_y = y;
            }
        }
        println!("Updated current position: ({}, {})", curr_x, curr_y);
    }
}

fn run_event_loop(chan: Chan<Event>) {
    // just testing = we don't actually loop
    chan.send(Pos(3, 4));
    chan.send(Pos(0, -2));
    chan.send(Pos(-3, 1));
}