kurnevsky on master
chore: add note about merge int… (compare)
kurnevsky on v0.2.0
kurnevsky on release-0.2.0
kurnevsky on master
refactor(clippy): fix warnings chore(cargo): release 0.2.0 Merge pull request #469 from to… (compare)
kurnevsky on release-0.2.0
refactor(clippy): fix warnings chore(cargo): release 0.2.0 (compare)
kurnevsky on release-0.2.0
refactor(clippy): fix warnings (compare)
kurnevsky on release-0.2.0
chore(cargo): release 0.2.0 (compare)
kpp on update_deps
kpp on master
chore(deps): update lru chore(deps): update clap chore(node): validate motd len and 7 more (compare)
Do you do it all on enthusiasm? :)
No we didn't. But things changed.
pkgver() {
cd "$pkgname"
git describe --long --tags | sed 's/\([^-]*-g\)/r\1/;s/-/./g'
}
pub fn spawn(self, dht_sk: SecretKey, dht_pk: PublicKey) -> impl Future<Item = (), Error = SpawnError> + Send { // TODO: send pings periodically
future::lazy(move || {
let relay_pk = self.pk;
let self_c = self.clone();
match *self.status.write() {
ref mut status @ ClientStatus::Disconnected
| ref mut status @ ClientStatus::Sleeping => *status = ClientStatus::Connecting,
_ => return future::ok(()),
}
let future = TcpStream::connect(&self.addr)
.and_then(move |socket| make_client_handshake(socket, &dht_pk, &dht_sk, &relay_pk)) // TODO: timeout
.and_then(move |(socket, channel)| {
let stats = Stats::new();
let secure_socket = Framed::new(socket, Codec::new(channel, stats));
make_client_handshake(socket, &dht_pk, &dht_sk, &relay_pk)
return with error type of std::io::Error
.
spawn
returns with error type of SpawnError
.