async fn handle_response(&mut self, response: zn::Response) -> Result<(), BoxError> {
        let transaction_ids: HashSet<_> = match response {
            zn::Response::TransactionIds(ids) => ids.into_iter().collect(),
            _ => unreachable!("Peer set did not respond with transaction IDs to mempool crawler"),
        };

        trace!(
            "Mempool crawler received {} transaction IDs",
            transaction_ids.len()
        );

        if !transaction_ids.is_empty() {
            self.queue_transactions(transaction_ids).await?;
        }

        Ok(())
    }
/// Handle a peer's response to the crawler's request for transactions.
Handle a peer's response to the crawler's request for transactions.
Handle a peer ' s response to the crawler ' s request for transactions .
async fn handle_response(&mut self, response: zn::Response) -> Result<(), BoxError> {
        let transaction_ids: HashSet<_> = match response {
            zn::Response::TransactionIds(ids) => ids.into_iter().collect(),
            _ => unreachable!("Peer set did not respond with transaction IDs to mempool crawler"),
        };
        trace!(
            "Mempool crawler received {} transaction IDs",
            transaction_ids.len()
        );
        if !transaction_ids.is_empty() {
            self.queue_transactions(transaction_ids).await?;
        }
        Ok(())
    }
async fn handle_response ( & mut self , response : zn :: Response ) -> Result < ( ) , BoxError > { let transaction_ids : HashSet < _ > = match response { zn :: Response :: TransactionIds ( ids ) => ids . into_iter ( ) . collect ( ) , _ => unreachable ! ( " " ) , } ; trace ! ( " " transaction_ids len ( ) ) ; if ! transaction_ids . is_empty ( ) { self . queue_transactions ( transaction_ids ) . await ? ; } Ok ( ( ) ) }
Handle a peer's response to the crawler's request for transactions.
Handle a peer ' s response to the crawler ' s request for transactions .
&mut self
response
zn::Response