/// Return the progress of this sequencer
Return the progress of this sequencer
Return the progress of this sequencer
async fn progress(&self) -> SequencerProgress {
        let namespaces: Vec<_> = self.namespaces.read().values().map(Arc::clone).collect();
        let mut progress = SequencerProgress::new();
        for namespace_data in namespaces {
            progress = progress.combine(namespace_data.progress().await);
        }
        progress
    }
async fn progress ( & self ) -> SequencerProgress { let namespaces : Vec < _ > = self . namespaces . read ( ) . values ( ) . map ( Arc :: clone ) . collect ( ) ; let mut progress = SequencerProgress :: new ( ) ; for namespace_data in namespaces { progress = progress . combine ( namespace_data . progress ( ) . await ) ; } progress }
Return the progress of this sequencer
Return the progress of this sequencer
&self