rustdds 0.7.9

Native Rust DDS implementation with RTPS
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

// use serde::de::DeserializeOwned;
// use mio_extras::channel as mio_channel;

// use crate::{
//   dds::{With_Key_DataReader as DataReader},
//   dds::statusevents::DataReaderStatus,
//   dds::traits::Keyed,
//   serialization::DeserializerAdapter,
//   dds::with_key::ReaderCommand,
// };

//   This file was helper methods for setting the receiver and commander fields
//   on a DataReader. These fields are now private so this can't exist and the
// tests   using it need to be rewritten

// #[cfg(test)]
// pub(crate) trait DataReaderTestUtil {
//   fn set_status_change_receiver(&mut self, receiver:
// mio_channel::Receiver<DataReaderStatus>);   fn set_reader_commander(&mut
// self, commander: mio_channel::SyncSender<ReaderCommand>); }

// #[cfg(test)]
// impl<D, DA> DataReaderTestUtil for DataReader<D, DA>
// where
//   D: Keyed + DeserializeOwned,
//   DA: DeserializerAdapter<D>,
// {
//   fn set_status_change_receiver(&mut self, receiver:
// mio_channel::Receiver<DataReaderStatus>) {     self.status_receiver =
// receiver;   }

//   fn set_reader_commander(&mut self, commander:
// mio_channel::SyncSender<ReaderCommand>) {     self.reader_command =
// commander;   }
// }