/// process a push message to the network
process a push message to the network
process a push message to the network
pub fn process_push_message(
        &mut self,
        from: &Pubkey,
        values: Vec<CrdsValue>,
        now: u64,
    ) -> Vec<VersionedCrdsValue> {
        values
            .into_iter()
            .filter_map(|val| {
                let res = self
                    .push
                    .process_push_message(&mut self.crds, from, val, now);
                if let Ok(Some(val)) = res {
                    self.pull
                        .record_old_hash(val.value_hash, val.local_timestamp);
                    Some(val)
                } else {
                    None
                }
            })
            .collect()
    }
pub fn process_push_message ( & mut self , from : & Pubkey , values : Vec < CrdsValue > , now : u64 , ) -> Vec < VersionedCrdsValue > { values . into_iter ( ) . filter_map ( | val | { let res = self . push . process_push_message ( & mut self . crds , from , val , now ) ; if let Ok ( Some ( val ) ) = res { self . pull . record_old_hash ( val . value_hash , val . local_timestamp ) ; Some ( val ) } else { None } } ) . collect ( ) }
process a push message to the network
process a push message to the network
&mut self
from
&Pubkey
values
Vec<CrdsValue>
now
u64