pub fn commit(&self, version: u64) -> impl Future<Output = Result<()>> {
        let mut sender = self.coordinator_sender.clone();
        async move {
            sender
                .send(ConsensusToCoordinatorMessage::Commit(version))
                .await?;
            Ok(())
        }
    }
/// Notifies state synchronizer about new version
Notifies state synchronizer about new version
Notifies state synchronizer about new version
pub fn commit(&self, version: u64) -> impl Future<Output = Result<()>> {
        let mut sender = self.coordinator_sender.clone();
        async move {
            sender
                .send(ConsensusToCoordinatorMessage::Commit(version))
                .await?;
            Ok(())
        }
    }
pub fn commit ( & self , version : u64 ) -> impl Future < Output = Result < ( ) > > { let mut sender = self . coordinator_sender . clone ( ) ; async move { sender . send ( ConsensusToCoordinatorMessage :: Commit ( version ) ) . await ? ; Ok ( ( ) ) } }
Notifies state synchronizer about new version
Notifies state synchronizer about new version
&self
version
u64
&self
version
u64