aboutsummaryrefslogtreecommitdiff
path: root/examples/basalt.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-07-21 19:25:07 +0200
committerAlex Auvolat <alex@adnab.me>2022-07-21 19:25:07 +0200
commit7d148c7e764d563efa3bccc0f14f50867db38ef1 (patch)
treebd2f968b1f2d82b8c95ab7367fa7a282f97f0850 /examples/basalt.rs
parent44bbc1c00c2532e08dff0d4a547b0a707e89f32d (diff)
downloadnetapp-7d148c7e764d563efa3bccc0f14f50867db38ef1.tar.gz
netapp-7d148c7e764d563efa3bccc0f14f50867db38ef1.zip
One possibility, but I don't like it
Diffstat (limited to 'examples/basalt.rs')
-rw-r--r--examples/basalt.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/examples/basalt.rs b/examples/basalt.rs
index 52fab4b..dd56cd7 100644
--- a/examples/basalt.rs
+++ b/examples/basalt.rs
@@ -16,7 +16,6 @@ use tokio::sync::watch;
use netapp::endpoint::*;
use netapp::message::*;
use netapp::peering::basalt::*;
-use netapp::send::*;
use netapp::util::parse_peer_addr;
use netapp::{NetApp, NodeID};
@@ -146,7 +145,7 @@ impl Example {
tokio::spawn(async move {
match self2
.example_endpoint
- .call(&p, &ExampleMessage { example_field: 42 }, PRIO_NORMAL)
+ .call(&p, ExampleMessage { example_field: 42 }, PRIO_NORMAL)
.await
{
Ok(resp) => debug!("Got example response: {:?}", resp),
@@ -160,7 +159,7 @@ impl Example {
#[async_trait]
impl EndpointHandler<ExampleMessage> for Example {
- async fn handle(self: &Arc<Self>, msg: &ExampleMessage, _from: NodeID) -> ExampleResponse {
+ async fn handle(self: &Arc<Self>, msg: ExampleMessage, _from: NodeID) -> ExampleResponse {
debug!("Got example message: {:?}, sending example response", msg);
ExampleResponse {
example_field: false,