/// Handle an incoming basenode response message
Handle an incoming basenode response message
Handle an incoming basenode response message
async fn handle_base_node_response(
        &mut self,
        response: BaseNodeProto::BaseNodeServiceResponse,
    ) -> Result<(), OutputManagerError>
    {
        // Publish this response to any protocols that are subscribed
        if let Err(_e) = self.base_node_response_publisher.send(Arc::new(response)) {
            trace!(
                target: LOG_TARGET,
                "Could not publish Base Node Response, no subscribers to receive."
            );
        }
        Ok(())
    }
async fn handle_base_node_response ( & mut self , response : BaseNodeProto :: BaseNodeServiceResponse , ) -> Result < ( ) , OutputManagerError > { // Publish this response to any protocols that are subscribed if let Err ( _e ) = self . base_node_response_publisher . send ( Arc :: new ( response ) ) { trace ! ( target LOG_TARGET " " ) ; } Ok ( ( ) ) }
Handle an incoming basenode response message
Handle an incoming basenode response message
&mut self
response
BaseNodeProto::BaseNodeServiceResponse