Method handle_automatic_command

bridge/src/client/cli/client_command.rs:385–401

(&mut self)

    }

    pub async fn handle_automatic_command(&mut self) -> io::Result<()> {
        loop {
            self.client.sync().await;

            let old_data = self.client.data().clone();

            self.client.process_peg_ins().await;
            self.client.process_peg_outs().await;

            // A bit inefficient, but fine for now: only flush if data changed
            if self.client.data() != &old_data {
                self.client.flush().await;
            } else {
                sleep(Duration::from_millis(250)).await;
            }
        }
    }

    // TODO: there are verifier's commands missing here
    pub fn get_broadcast_command() -> Command {