pub fn process_push_message(
        &self,
        from: &Pubkey,
        values: Vec<CrdsValue>,
        now: u64,
    ) -> (usize, HashSet<Pubkey>) {
        let results = self
            .push
            .process_push_message(&self.crds, from, values, now);
        let mut success_count = 0;
        let successfully_inserted_origin_set: HashSet<Pubkey> = results
            .into_iter()
            .filter_map(|result| {
                if result.is_ok() {
                    success_count += 1;
                }
                Result::ok(result)
            })
            .collect();

        (success_count, successfully_inserted_origin_set)
    }
/// Process a push message to the network.
///
/// Returns unique origins' pubkeys of upserted values.
Process a push message to the network.
Returns unique origins' pubkeys of upserted values.
Process a push message to the network . Returns unique origins ' pubkeys of upserted values .
pub fn process_push_message(
        &self,
        from: &Pubkey,
        values: Vec<CrdsValue>,
        now: u64,
    ) -> (usize, HashSet<Pubkey>) {
        let results = self
            .push
            .process_push_message(&self.crds, from, values, now);
        let mut success_count = 0;
        let successfully_inserted_origin_set: HashSet<Pubkey> = results
            .into_iter()
            .filter_map(|result| {
                if result.is_ok() {
                    success_count += 1;
                }
                Result::ok(result)
            })
            .collect();
        (success_count, successfully_inserted_origin_set)
    }
pub fn process_push_message ( & self , from : & Pubkey , values : Vec < CrdsValue > , now : u64 , ) -> ( usize , HashSet < Pubkey > ) { let results = self . push . process_push_message ( & self . crds , from , values , now ) ; let mut success_count = 0 ; let successfully_inserted_origin_set : HashSet < Pubkey > = results . into_iter ( ) . filter_map ( | result | { if result . is_ok ( ) { success_count += 1 ; } Result :: ok ( result ) } ) . collect ( ) ; ( success_count , successfully_inserted_origin_set ) }
Process a push message to the network.
Process a push message to the network .
&self
from
&Pubkey
values
Vec<CrdsValue>
now
u64