aboutsummaryrefslogtreecommitdiff
path: root/src/endpoint.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-02-21 12:01:04 +0100
committerAlex Auvolat <alex@adnab.me>2022-02-21 12:01:04 +0100
commit3b8bff634198c5ae17ab16d5c85c30b3201ae593 (patch)
tree8f3545c230c08c3a3100faf1293345e88a43d3dd /src/endpoint.rs
parent109d6c143d01b2d59027d45738692fa8ef6253ee (diff)
downloadnetapp-3b8bff634198c5ae17ab16d5c85c30b3201ae593.tar.gz
netapp-3b8bff634198c5ae17ab16d5c85c30b3201ae593.zip
Refactoring
Diffstat (limited to 'src/endpoint.rs')
-rw-r--r--src/endpoint.rs10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/endpoint.rs b/src/endpoint.rs
index 760bf32..b408241 100644
--- a/src/endpoint.rs
+++ b/src/endpoint.rs
@@ -1,5 +1,6 @@
use std::marker::PhantomData;
use std::sync::Arc;
+use std::borrow::Borrow;
use arc_swap::ArcSwapOption;
use async_trait::async_trait;
@@ -88,16 +89,17 @@ where
/// Call this endpoint on a remote node (or on the local node,
/// for that matter)
- pub async fn call(
+ pub async fn call<B>(
&self,
target: &NodeID,
- req: &M,
+ req: B,
prio: RequestPriority,
- ) -> Result<<M as Message>::Response, Error> {
+ ) -> Result<<M as Message>::Response, Error>
+ where B: Borrow<M> {
if *target == self.netapp.id {
match self.handler.load_full() {
None => Err(Error::NoHandler),
- Some(h) => Ok(h.handle(req, self.netapp.id).await),
+ Some(h) => Ok(h.handle(req.borrow(), self.netapp.id).await),
}
} else {
let conn = self