Sender abstraction has ID and name #39
@ -24,24 +24,6 @@ pub enum CustomTmSenderError {
|
|||||||
PusError(PusError),
|
PusError(PusError),
|
||||||
}
|
}
|
||||||
|
|
||||||
// #[derive(Clone)]
|
|
||||||
// struct EventTmSender {
|
|
||||||
// sender: std::sync::mpsc::Sender<Vec<u8>>,
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// impl EcssTmSenderCore for EventTmSender {
|
|
||||||
// type Error = CustomTmSenderError;
|
|
||||||
// fn send_tm(&mut self, tm: PusTm) -> Result<(), Self::Error> {
|
|
||||||
// let mut vec = Vec::new();
|
|
||||||
// tm.append_to_vec(&mut vec)
|
|
||||||
// .map_err(|e| CustomTmSenderError::PusError(e))?;
|
|
||||||
// self.sender
|
|
||||||
// .send(vec)
|
|
||||||
// .map_err(CustomTmSenderError::SendError)?;
|
|
||||||
// Ok(())
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn test_threaded_usage() {
|
fn test_threaded_usage() {
|
||||||
let (event_sender, event_man_receiver) = channel();
|
let (event_sender, event_man_receiver) = channel();
|
||||||
|
Loading…
Reference in New Issue
Block a user