// type FutureUnit = futures::future::Ready<Result<(Self, Session), anyhow::Error>>;

        // futures::future::ready(Ok((self, session)))

                }
                State::Channel { ref mut sender } => {
                    debug!("state channel");
                    sender.send(data).await?

                State::Channel { ref mut sender } => sender.send(data).await?,

                    debug!("state archive");

            debug!("receiving channel");

                debug!("msg = {:?}", msg.len());

                    debug!("break");

            debug!("from dump done");

                self.c
                    .data(format!("change {}\n", h.to_base32()).as_bytes())
                    .await?;

                self.c
                    .data(format!("change {}\n", h.to_base32()).as_bytes())
                    .await?;

        debug!("hashes = {:?}", hashes);

        debug!("hashes = {:#?}", hashes);

        self.download_changes(&hashes, &mut send, &mut repo.changes_dir, false)

        self.download_changes(&hashes, &mut send, &mut repo.changes_dir, true)

        remote.finish().await?;