main.rs

machine Protocol for ProtocolData {
    <*> => wait_for_leader / set_randomized_timeout;
    wait_for_leader + Timeout => leader;

    machine leader {
        entry / set_timer, transmit_data;
        exit / cancel_timer;
        self + Timeout / transmit_data;
        self + p: TransmitData / packet = p;
    }

    self + d: ReceivedData => follower / received_data(d);
    self + p: TransmitData => leader / packet = p;
}