fn complete_coinbase_transaction_monitoring_protocol(
        &mut self,
        join_result: Result<u64, TransactionServiceProtocolError>,
    )
    {
        match join_result {
            Ok(id) => {
                // Cleanup any registered senders
                let _ = self.base_node_response_senders.remove(&id);

                trace!(
                    target: LOG_TARGET,
                    "Coinbase Transaction monitoring Protocol for TxId: {} completed successfully",
                    id
                );
            },
            Err(TransactionServiceProtocolError { id, error }) => {
                let _ = self.base_node_response_senders.remove(&id);
                if let TransactionServiceError::Shutdown = error {
                    return;
                }
                warn!(
                    target: LOG_TARGET,
                    "Error completing Coinbase Transaction monitoring Protocol (Id: {}): {:?}", id, error
                );
                let _ = self
                    .event_publisher
                    .send(Arc::new(TransactionEvent::Error(format!("{:?}", error))));
            },
        }
    }
/// Handle the final clean up after a Coinbase Transaction Monitoring protocol completes
Handle the final clean up after a Coinbase Transaction Monitoring protocol completes
Handle the final clean up after a Coinbase Transaction Monitoring protocol completes
fn complete_coinbase_transaction_monitoring_protocol(
        &mut self,
        join_result: Result<u64, TransactionServiceProtocolError>,
    )
    {
        match join_result {
            Ok(id) => {
                // Cleanup any registered senders
                let _ = self.base_node_response_senders.remove(&id);
                trace!(
                    target: LOG_TARGET,
                    "Coinbase Transaction monitoring Protocol for TxId: {} completed successfully",
                    id
                );
            },
            Err(TransactionServiceProtocolError { id, error }) => {
                let _ = self.base_node_response_senders.remove(&id);
                if let TransactionServiceError::Shutdown = error {
                    return;
                }
                warn!(
                    target: LOG_TARGET,
                    "Error completing Coinbase Transaction monitoring Protocol (Id: {}): {:?}", id, error
                );
                let _ = self
                    .event_publisher
                    .send(Arc::new(TransactionEvent::Error(format!("{:?}", error))));
            },
        }
    }
fn complete_coinbase_transaction_monitoring_protocol ( & mut self , join_result : Result < u64 , TransactionServiceProtocolError > , ) { match join_result { Ok ( id ) => { // Cleanup any registered senders let _ = self . base_node_response_senders . remove ( & id ) ; trace ! ( target LOG_TARGET " " id ) ; } , Err ( TransactionServiceProtocolError { id , error } ) => { let _ = self . base_node_response_senders . remove ( & id ) ; if let TransactionServiceError :: Shutdown = error { return ; } warn ! ( target LOG_TARGET " " id error ) ; let _ = self . event_publisher . send ( Arc :: new ( TransactionEvent :: Error ( format ! ( " " error ) ) ) ) ; } , } }
Handle the final clean up after a Coinbase Transaction Monitoring protocol completes
Handle the final clean up after a Coinbase Transaction Monitoring protocol completes
&mut self
join_result
Result<u64, TransactionServiceProtocolError>
&mut self
join_result
Result<u64, TransactionServiceProtocolError>