QE64ATLZWMKHYABCD3VA547PYXCK6YN3K7RE2TX3SCQNKG7XLVAQC
I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC
UDHP4ZVBQZT2VBURB2MDCU2IZDNMCAFSIUKWRBDQ5BWMFKSN2LYQC
SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC
// 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 } => {
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?;