Method observer_can_receive

nodedb-raft/src/state.rs:229–235

Whether an observer's send queue is below the backpressure threshold. Returns `false` if the observer is unknown.

(&self, observer: u64)

    /// Whether an observer's send queue is below the backpressure threshold.
    /// Returns `false` if the observer is unknown.
    pub fn observer_can_receive(&self, observer: u64) -> bool {
        self.observer_states
            .iter()
            .find(|(id, _)| *id == observer)
            .map(|(_, state)| state.pending_count < ObserverState::MAX_PENDING)
            .unwrap_or(false)
    }
}

#[cfg(test)]