async fn queue_transactions(
        &mut self,
        transaction_ids: HashSet<UnminedTxId>,
    ) -> Result<(), BoxError> {
        let transaction_ids = transaction_ids.into_iter().map(Gossip::Id).collect();

        let call_result = self
            .mempool
            .ready()
            .await?
            .call(mempool::Request::Queue(transaction_ids))
            .await;

        let queue_errors = match call_result {
            Ok(mempool::Response::Queued(queue_results)) => {
                queue_results.into_iter().filter_map(Result::err)
            }
            Ok(_) => unreachable!("Mempool did not respond with queue results to mempool crawler"),
            Err(call_error) => {
                debug!("Ignoring unexpected peer behavior: {}", call_error);
                return Ok(());
            }
        };

        for error in queue_errors {
            debug!("Failed to download a crawled transaction: {}", error);
        }

        Ok(())
    }
/// Forward the crawled transactions IDs to the mempool transaction downloader.
Forward the crawled transactions IDs to the mempool transaction downloader.
Forward the crawled transactions IDs to the mempool transaction downloader .
async fn queue_transactions(
        &mut self,
        transaction_ids: HashSet<UnminedTxId>,
    ) -> Result<(), BoxError> {
        let transaction_ids = transaction_ids.into_iter().map(Gossip::Id).collect();
        let call_result = self
            .mempool
            .ready()
            .await?
            .call(mempool::Request::Queue(transaction_ids))
            .await;
        let queue_errors = match call_result {
            Ok(mempool::Response::Queued(queue_results)) => {
                queue_results.into_iter().filter_map(Result::err)
            }
            Ok(_) => unreachable!("Mempool did not respond with queue results to mempool crawler"),
            Err(call_error) => {
                debug!("Ignoring unexpected peer behavior: {}", call_error);
                return Ok(());
            }
        };
        for error in queue_errors {
            debug!("Failed to download a crawled transaction: {}", error);
        }
        Ok(())
    }
async fn queue_transactions ( & mut self , transaction_ids : HashSet < UnminedTxId > , ) -> Result < ( ) , BoxError > { let transaction_ids = transaction_ids . into_iter ( ) . map ( Gossip :: Id ) . collect ( ) ; let call_result = self . mempool . ready ( ) . await ? . call ( mempool :: Request :: Queue ( transaction_ids ) ) . await ; let queue_errors = match call_result { Ok ( mempool :: Response :: Queued ( queue_results ) ) => { queue_results . into_iter ( ) . filter_map ( Result :: err ) } Ok ( _ ) => unreachable ! ( " " ) , Err ( call_error ) => { debug ! ( " " call_error ) ; return Ok ( ( ) ) ; } } ; for error in queue_errors { debug ! ( " " error ) ; } Ok ( ( ) ) }
Forward the crawled transactions IDs to the mempool transaction downloader.
Forward the crawled transactions IDs to the mempool transaction downloader .
&mut self
transaction_ids
HashSet<UnminedTxId>