pub(crate) async fn handle_error(&mut self, error: EstablishError) {
        let reason = ServerUpdate::Error { error };

        let (message, callback) = AcknowledgedMessage::package(reason);
        // These only fails if the other ends hang up, which means the monitor is
        // stopped, so we can just discard this update.
        let _: std::result::Result<_, _> = self.sender.send(message).await;
        callback.wait_for_acknowledgment().await;
    }
/// Update the server based on the given error.
/// This will block until the topology has processed the error.
Update the server based on the given error.
This will block until the topology has processed the error.
Update the server based on the given error . This will block until the topology has processed the error .
pub(crate) async fn handle_error(&mut self, error: EstablishError) {
        let reason = ServerUpdate::Error { error };
        let (message, callback) = AcknowledgedMessage::package(reason);
        // These only fails if the other ends hang up, which means the monitor is
        // stopped, so we can just discard this update.
        let _: std::result::Result<_, _> = self.sender.send(message).await;
        callback.wait_for_acknowledgment().await;
    }
pub ( crate ) async fn handle_error ( & mut self , error : EstablishError ) { let reason = ServerUpdate :: Error { error } ; let ( message , callback ) = AcknowledgedMessage :: package ( reason ) ; // These only fails if the other ends hang up, which means the monitor is // stopped, so we can just discard this update. let _ : std :: result :: Result < _ , _ > = self . sender . send ( message ) . await ; callback . wait_for_acknowledgment ( ) . await ; }
Update the server based on the given error.
Update the server based on the given error .
&mut self
error
EstablishError
&mut self
error
EstablishError