diff options
author | Alex Auvolat <alex@adnab.me> | 2022-07-22 10:55:37 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2022-07-22 10:55:37 +0200 |
commit | c358fe3c92da8a8454e461484737efe2a14dfd73 (patch) | |
tree | db540e2e25a96585686826ef66f3552decee96df /examples/basalt.rs | |
parent | 4934ed726d51913afd97ca937d0ece39ef8b7371 (diff) | |
download | netapp-c358fe3c92da8a8454e461484737efe2a14dfd73.tar.gz netapp-c358fe3c92da8a8454e461484737efe2a14dfd73.zip |
Hide streaming versions as much as possible
Diffstat (limited to 'examples/basalt.rs')
-rw-r--r-- | examples/basalt.rs | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/examples/basalt.rs b/examples/basalt.rs index 3841786..a5a25c3 100644 --- a/examples/basalt.rs +++ b/examples/basalt.rs @@ -159,15 +159,11 @@ impl Example { #[async_trait] impl EndpointHandler<ExampleMessage> for Example { - async fn handle( - self: &Arc<Self>, - msg: Req<ExampleMessage>, - _from: NodeID, - ) -> Resp<ExampleMessage> { + async fn handle(self: &Arc<Self>, msg: &ExampleMessage, _from: NodeID) -> ExampleResponse { debug!("Got example message: {:?}, sending example response", msg); - Resp::new(ExampleResponse { + ExampleResponse { example_field: false, - }) + } } } |