From 7967b955532d338df9279f589db7a89dc4f0fef7 Mon Sep 17 00:00:00 2001 From: Robin Mueller Date: Thu, 22 Feb 2024 15:51:51 +0100 Subject: [PATCH] this is not easy --- satrs/src/request.rs | 28 +++++++++------------------- 1 file changed, 9 insertions(+), 19 deletions(-) diff --git a/satrs/src/request.rs b/satrs/src/request.rs index 572a232..4ef482c 100644 --- a/satrs/src/request.rs +++ b/satrs/src/request.rs @@ -138,32 +138,22 @@ mod std_mod { use super::MessageWithSenderId; - pub trait TargetedMessageSendProvider { - type Message; - fn send_message( - &self, - local_channel_id: ChannelId, - target_channel_id: ChannelId, - message: Self::Message, - ) -> Result<(), GenericTargetedMessagingError>; - } - - pub struct MpscMessageSenderMap>( - pub HashMap, + pub struct MpscMessageSenderMap( + pub HashMap>>, ); - impl Default for MpscMessageSenderMap { + impl Default for MpscMessageSenderMap { fn default() -> Self { Self(Default::default()) } } - impl MpscMessageSenderMap { + impl MpscMessageSenderMap { pub fn send_message( &self, local_channel_id: ChannelId, target_channel_id: ChannelId, - message: Message, + message: MESSAGE, ) -> Result<(), GenericTargetedMessagingError> { if self.0.contains_key(&target_channel_id) { self.0 @@ -181,18 +171,18 @@ mod std_mod { pub fn add_message_target( &mut self, target_id: ChannelId, - message_sender: mpsc::Sender>, + message_sender: mpsc::Sender>, ) { self.0.insert(target_id, message_sender); } } - pub struct MpscMessageSenderWithId { + pub struct MpscMessageSenderWithId { pub local_channel_id: ChannelId, - pub message_sender_map: MpscMessageSenderMap, + pub message_sender_map: MpscMessageSenderMap, } - impl MpscMessageSenderWithId { + impl MpscMessageSenderWithId { pub fn new(local_channel_id: ChannelId) -> Self { Self { local_channel_id,