Add two unit test cases

Add two unit test cases for SubscriberId and remote endpoint.

Signed-off-by: Liu Jiang <[email protected]>

src/lib.rs

@@ -273,3 +273,22 @@ impl<T: MutEventSubscriber + ?Sized> MutEventSubscriber for Box<T> {
         self.deref_mut().init(ops);
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_subscriber_id_derives() {
+        let a = SubscriberId(1);
+        let b = SubscriberId(1);
+        let c = SubscriberId(2);
+
+        assert_eq!(a, b);
+        assert_ne!(a, c);
+        assert_ne!(c, b);
+
+        let d = c.clone();
+        assert_eq!(c, d);
+    }
+}

src/manager.rs

@@ -497,4 +497,31 @@ mod tests {
             Error::InvalidId
         );
     }
+
+    #[test]
+    #[cfg(feature = "remote_endpoint")]
+    fn test_endpoint() {
+        use std::thread;
+
+        let mut event_manager = EventManager::<DummySubscriber>::new().unwrap();
+        let dummy = DummySubscriber::new();
+        let endpoint = event_manager.remote_endpoint();
+        let kicker = event_manager.remote_endpoint();
+
+        let thread_handle = thread::spawn(move || {
+            event_manager.run().unwrap();
+            event_manager.run().unwrap();
+        });
+
+        dummy.event_fd_1.write(1).unwrap();
+
+        let token = endpoint
+            .call_blocking(|sub_ops| -> Result<SubscriberId> { Ok(sub_ops.add_subscriber(dummy)) })
+            .unwrap();
+        assert_eq!(token, SubscriberId(1));
+
+        kicker.kick().unwrap();
+
+        thread_handle.join().unwrap();
+    }
 }