eq.zz

struct UdpLogger
{
    udp::Socket sock;
    string::String+1000 buf;
    udp::ReceiveEvent ev;
}


fn my_udp_logger_poll(UdpLogger mut*self, async::Eq mut*eq)
{
    switch self->ev.state() {
        async::State::Parked => {
            return;
        },
        async::State::Error  => {
            ev->error.abort();
            return;
        }
        async::State::Ready => {
            log::info("got %s", self->buf.mem);
        }
        async::State::Invalid => {
        }
    }
    self->ev = self->sock.recv(self->buf.to_mut_slice());
}


fn main() {
    new eq = async::eventqueue();

    for (;;) {
        my_udp_logger_poll(eq);
        eq.wait();
    }
}