fn control_message_monitor(receiver: Receiver<ManagerControlMessage>, broadcaster: UnitBroadcaster) {
        while let Ok(msg) = receiver.recv() {
            broadcaster.broadcast(&UnitEvent::ManagerRequest(msg));
        }
    }
/// Runs in a separate thread and consolidates control messages

Runs in a separate thread and consolidates control messages
Runs in a separate thread and consolidates control messages
fn control_message_monitor(receiver: Receiver<ManagerControlMessage>, broadcaster: UnitBroadcaster) {
        while let Ok(msg) = receiver.recv() {
            broadcaster.broadcast(&UnitEvent::ManagerRequest(msg));
        }
    }
fn control_message_monitor ( receiver : Receiver < ManagerControlMessage > , broadcaster : UnitBroadcaster ) { while let Ok ( msg ) = receiver . recv ( ) { broadcaster . broadcast ( & UnitEvent :: ManagerRequest ( msg ) ) ; } }
Runs in a separate thread and consolidates control messages
Runs in a separate thread and consolidates control messages
receiver
Receiver<ManagerControlMessage>
broadcaster
UnitBroadcaster
receiver
Receiver<ManagerControlMessage>
broadcaster
UnitBroadcaster