Method add_ntp_source

clock-bound/src/daemon/receiver_stream.rs:46–49

Adds a new ntp source to the `ntp_sources`

(&mut self, source: NTPSourceReceiver)

impl ReceiverStream {
    /// Adds a new ntp source to the `ntp_sources`
    pub fn add_ntp_source(&mut self, source: NTPSourceReceiver) {
        let (socket_addr, receiver) = source;
        let _ = &self.ntp_sources.insert(socket_addr, receiver);
    }

    /// Removes an ntp source from `ntp_sources`
    pub fn remove_ntp_source(&mut self, id: &SocketAddr) {