async fn notify(&self, msg: LedgerMessage) -> Result<(), GovernanceError> {
        let (tx, rx) = oneshot::channel::<Result<(), GovernanceError>>();
        self.observer.unbounded_send((msg, tx)).unwrap();
        rx.await
            .map_err(|_e| GovernanceError::new(ErrorType::Unavailable))?
    }
// Notifies the observer that a ledger method has been called, and blocks until
// it receives a message to continue.
Notifies the observer that a ledger method has been called, and blocks until
it receives a message to continue.
Notifies the observer that a ledger method has been called and blocks until it receives a message to continue .
async fn notify(&self, msg: LedgerMessage) -> Result<(), GovernanceError> {
        let (tx, rx) = oneshot::channel::<Result<(), GovernanceError>>();
        self.observer.unbounded_send((msg, tx)).unwrap();
        rx.await
            .map_err(|_e| GovernanceError::new(ErrorType::Unavailable))?
    }
async fn notify ( & self , msg : LedgerMessage ) -> Result < ( ) , GovernanceError > { let ( tx , rx ) = oneshot :: channel :: < Result < ( ) , GovernanceError > > ( ) ; self . observer . unbounded_send ( ( msg , tx ) ) . unwrap ( ) ; rx . await . map_err ( | _e | GovernanceError :: new ( ErrorType :: Unavailable ) ) ? }
Notifies the observer that a ledger method has been called, and blocks until
it receives a message to continue.
Notifies the observer that a ledger method has been called and blocks until it receives a message to continue .
&self
msg
LedgerMessage
&self
msg
LedgerMessage