fn process_events(&self, events: Vec<Event>) -> Result<()> {
        for result in self.acc.lock().unwrap().process_verified_events(events) {
            if let Ok(event) = result {
                self.historian_input
                    .lock()
                    .unwrap()
                    .send(Signal::Event(event))?;
            }
        }

        // Let validators know they should not attempt to process additional
        // transactions in parallel.
        self.historian_input.lock().unwrap().send(Signal::Tick)?;
        debug!("after historian_input");

        Ok(())
    }
/// Process the transactions in parallel and then log the successful ones.
Process the transactions in parallel and then log the successful ones.
Process the transactions in parallel and then log the successful ones .
fn process_events(&self, events: Vec<Event>) -> Result<()> {
        for result in self.acc.lock().unwrap().process_verified_events(events) {
            if let Ok(event) = result {
                self.historian_input
                    .lock()
                    .unwrap()
                    .send(Signal::Event(event))?;
            }
        }
        // Let validators know they should not attempt to process additional
        // transactions in parallel.
        self.historian_input.lock().unwrap().send(Signal::Tick)?;
        debug!("after historian_input");
        Ok(())
    }
fn process_events ( & self , events : Vec < Event > ) -> Result < ( ) > { for result in self . acc . lock ( ) . unwrap ( ) . process_verified_events ( events ) { if let Ok ( event ) = result { self . historian_input . lock ( ) . unwrap ( ) . send ( Signal :: Event ( event ) ) ? ; } } // Let validators know they should not attempt to process additional // transactions in parallel. self . historian_input . lock ( ) . unwrap ( ) . send ( Signal :: Tick ) ? ; debug ! ( " " ) ; Ok ( ( ) ) }
Process the transactions in parallel and then log the successful ones.
Process the transactions in parallel and then log the successful ones .
&self
events
Vec<Event>
&self
events
Vec<Event>