diff options
| author | Alex <alex@adnab.me> | 2022-09-13 12:56:53 +0200 |
|---|---|---|
| committer | Alex <alex@adnab.me> | 2022-09-13 12:56:53 +0200 |
| commit | 8ac109e3a84bd34550d66baf65fe59b86b63bca2 (patch) | |
| tree | a49a199a1049d18afaa60f47f46e04cb798aa4b2 /src/peering/basalt.rs | |
| parent | a82700c5a27612002e6ee029ae77915b8114182f (diff) | |
| parent | 298e956a199711b65ce3820931ca943108b78225 (diff) | |
| download | netapp-baf978b0f26dc297d20708287a05b6e21976289a.tar.gz netapp-baf978b0f26dc297d20708287a05b6e21976289a.zip | |
Merge pull request 'add streaming body to requests and responses' (#3) from stream-body into mainv0.5.0
Reviewed-on: https://git.deuxfleurs.fr/lx/netapp/pulls/3
Diffstat (limited to 'src/peering/basalt.rs')
| -rw-r--r-- | src/peering/basalt.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/peering/basalt.rs b/src/peering/basalt.rs index cd70c2b..2c27dba 100644 --- a/src/peering/basalt.rs +++ b/src/peering/basalt.rs @@ -14,8 +14,8 @@ use sodiumoxide::crypto::hash; use tokio::sync::watch; use crate::endpoint::*; +use crate::message::*; use crate::netapp::*; -use crate::proto::*; use crate::NodeID; // -- Protocol messages -- @@ -331,7 +331,7 @@ impl Basalt { async fn do_pull(self: Arc<Self>, peer: NodeID) { match self .pull_endpoint - .call(&peer, &PullMessage {}, PRIO_NORMAL) + .call(&peer, PullMessage {}, PRIO_NORMAL) .await { Ok(resp) => { @@ -346,7 +346,7 @@ impl Basalt { async fn do_push(self: Arc<Self>, peer: NodeID) { let push_msg = self.make_push_message(); - match self.push_endpoint.call(&peer, &push_msg, PRIO_NORMAL).await { + match self.push_endpoint.call(&peer, push_msg, PRIO_NORMAL).await { Ok(_) => { trace!("KYEV PEXo {}", hex::encode(peer)); } |