use anyhow::bail;

    has_errors: Arc<Mutex<bool>>,

        let has_errors = Arc::new(Mutex::new(false));

            has_errors: has_errors.clone(),

            has_errors,

    has_errors: Arc<Mutex<bool>>,

        self,
        _channel: thrussh::ChannelId,
        session: thrussh::client::Session,
    ) -> Self::FutureUnit {
        Box::pin(async move {
            *self.state.lock().await = State::None;
            Ok((self, session))
        })
    }
    fn exit_status(

        _status: u32,

            *self.has_errors.lock().await = true;

                *super::SPINNER.lock().await = None;
                *self.has_errors.lock().await = true;

        if *self.has_errors.lock().await {
            bail!("Remote sent an error")
        }

use tokio::sync::Mutex;

    static ref SPINNER: Arc<Mutex<Option<indicatif::ProgressBar>>> = Arc::new(Mutex::new(None));

        *SPINNER.lock().await = Some(progress);

        progress.set_style(
            indicatif::ProgressStyle::default_spinner().template("✓ Updating remote changelist"),
        );
        progress.finish();

        if let Some(progress) = SPINNER.lock().await.take() {
            progress.set_style(
                indicatif::ProgressStyle::default_spinner()
                    .template("✓ Updating remote changelist"),
            );
            progress.finish();
        }