Method run

src/compression.rs:69–81

(self, control: &ControlToken<Self::Status>)

    type Status = ();

    fn run(self, control: &ControlToken<Self::Status>) -> Self::Output {
        for file in &self.files_in {
            if control.is_cancelled_with_pause() {
                break;
            }

            let file = file.0;
            let ret = handle_file(&file, self.compression);
            if self.files_out.send((file, ret)).is_err() {
                break;
            }
        }
    }
}