diff options
Diffstat (limited to 'src/peering/basalt.rs')
| -rw-r--r-- | src/peering/basalt.rs | 17 |
1 files changed, 4 insertions, 13 deletions
diff --git a/src/peering/basalt.rs b/src/peering/basalt.rs index 71dea84..310077f 100644 --- a/src/peering/basalt.rs +++ b/src/peering/basalt.rs @@ -468,24 +468,15 @@ impl Basalt { #[async_trait] impl EndpointHandler<PullMessage> for Basalt { - async fn handle( - self: &Arc<Self>, - _pullmsg: Req<PullMessage>, - _from: NodeID, - ) -> Resp<PullMessage> { - Resp::new(self.make_push_message()) + async fn handle(self: &Arc<Self>, _pullmsg: &PullMessage, _from: NodeID) -> PushMessage { + self.make_push_message() } } #[async_trait] impl EndpointHandler<PushMessage> for Basalt { - async fn handle( - self: &Arc<Self>, - pushmsg: Req<PushMessage>, - _from: NodeID, - ) -> Resp<PushMessage> { - self.handle_peer_list(&pushmsg.msg().peers[..]); - Resp::new(()) + async fn handle(self: &Arc<Self>, pushmsg: &PushMessage, _from: NodeID) { + self.handle_peer_list(&pushmsg.peers[..]); } } |