pub fn run(mut self) -> Result<(), BoxError> {
        let subscription_a = self.chains.a.subscribe()?;
        let subscription_b = self.chains.b.subscribe()?;

        loop {
            for batch in subscription_a.try_iter() {
                self.process_batch(self.chains.a.clone(), batch.unwrap_or_clone())?;
            }

            for batch in subscription_b.try_iter() {
                self.process_batch(self.chains.b.clone(), batch.unwrap_or_clone())?;
            }

            std::thread::sleep(Duration::from_millis(600));
        }
    }
/// Run the supervisor event loop.
Run the supervisor event loop.
Run the supervisor event loop .
pub fn run(mut self) -> Result<(), BoxError> {
        let subscription_a = self.chains.a.subscribe()?;
        let subscription_b = self.chains.b.subscribe()?;
        loop {
            for batch in subscription_a.try_iter() {
                self.process_batch(self.chains.a.clone(), batch.unwrap_or_clone())?;
            }
            for batch in subscription_b.try_iter() {
                self.process_batch(self.chains.b.clone(), batch.unwrap_or_clone())?;
            }
            std::thread::sleep(Duration::from_millis(600));
        }
    }
pub fn run ( mut self ) -> Result < ( ) , BoxError > { let subscription_a = self . chains . a . subscribe ( ) ? ; let subscription_b = self . chains . b . subscribe ( ) ? ; loop { for batch in subscription_a . try_iter ( ) { self . process_batch ( self . chains . a . clone ( ) , batch . unwrap_or_clone ( ) ) ? ; } for batch in subscription_b . try_iter ( ) { self . process_batch ( self . chains . b . clone ( ) , batch . unwrap_or_clone ( ) ) ? ; } std :: thread :: sleep ( Duration :: from_millis ( 600 ) ) ; } }
Run the supervisor event loop.
Run the supervisor event loop .
mut self
mut self