INNER CODE UNIT · Rust

run

sachaos/viddy · src/app.rs:173

    pub async fn run(&mut self) -> Result<()> {
        let (action_tx, mut action_rx) = mpsc::unbounded_channel();

        let records = self.store.get_records()?;
        for r in records {
            action_tx.send(Action::StartExecution(r.id, r.start_time))?;
            action_tx.send(Action::FinishExecution(
                r.id,
                r.end_time,
                r.diff,
                r.exit_code,
            ))?;
        }
        if self.read_only {
            action_tx.send(Action::SetTimemachineMode(true))?;
        }

        let executor_handle = if self.read_only {

View source record →