fn update(&mut self, sync_length: usize) {
        self.recent_lengths.insert(0, sync_length);

        self.recent_lengths.truncate(Self::MAX_RECENT_LENGTHS);

        // TODO: remove or downgrade this log to debug
        tracing::info!(
            recent_lengths = ?self.recent_lengths,
            "sending recent sync lengths"
        );

        // ignore dropped receivers
        let _ = self.sender.send(self.recent_lengths.clone());
    }
/// Sends a list update to listeners.
///
/// Prunes recent lengths, if the list is longer than `MAX_RECENT_LENGTHS`.
Sends a list update to listeners.
Prunes recent lengths, if the list is longer than `MAX_RECENT_LENGTHS`.
Sends a list update to listeners . Prunes recent lengths if the list is longer than ` MAX_RECENT_LENGTHS ` .
fn update(&mut self, sync_length: usize) {
        self.recent_lengths.insert(0, sync_length);
        self.recent_lengths.truncate(Self::MAX_RECENT_LENGTHS);
        // TODO: remove or downgrade this log to debug
        tracing::info!(
            recent_lengths = ?self.recent_lengths,
            "sending recent sync lengths"
        );
        // ignore dropped receivers
        let _ = self.sender.send(self.recent_lengths.clone());
    }
fn update ( & mut self , sync_length : usize ) { self . recent_lengths . insert ( 0 , sync_length ) ; self . recent_lengths . truncate ( Self :: MAX_RECENT_LENGTHS ) ; // TODO: remove or downgrade this log to debug tracing :: info ! ( recent_lengths self recent_lengths " " ) ; // ignore dropped receivers let _ = self . sender . send ( self . recent_lengths . clone ( ) ) ; }
Sends a list update to listeners.
Sends a list update to listeners .
&mut self
sync_length
usize