From ffb6fe83ada5d48c969d4983fd926fca4564e226 Mon Sep 17 00:00:00 2001
From: Robin Mueller <robin.mueller.m@gmail.com>
Date: Tue, 1 Nov 2022 20:07:02 +0100
Subject: [PATCH] test works

---
 fsrc-core/tests/pus_events.rs | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/fsrc-core/tests/pus_events.rs b/fsrc-core/tests/pus_events.rs
index 058b0f6..251f585 100644
--- a/fsrc-core/tests/pus_events.rs
+++ b/fsrc-core/tests/pus_events.rs
@@ -42,6 +42,7 @@ fn test_threaded_usage() {
     // PUS + Generic event manager thread
     let jh0 = thread::spawn(move || {
         let mut sender = EventTmSender { sender: event_tx };
+        let mut event_cnt = 0;
         loop {
             let res = event_man.try_event_handling();
             assert!(res.is_ok());
@@ -61,9 +62,12 @@ fn test_threaded_usage() {
                         event,
                         None,
                     );
+                    event_cnt += 1;
                     assert!(res.is_ok());
                     assert!(res.unwrap());
-                    break;
+                    if event_cnt == 2 {
+                        break;
+                    }
                 }
                 Err(e) => {
                     if let TryRecvError::Disconnected = e {
@@ -82,7 +86,10 @@ fn test_threaded_usage() {
         loop {
             match event_rx.try_recv() {
                 // Event TM received successfully
-                Ok(_) => break,
+                Ok(event) => {
+                    println!("{:x?}", event);
+                    break;
+                }
                 Err(e) => {
                     if let TryRecvError::Disconnected = e {
                         panic!("Event sender disconnected!")
@@ -99,7 +106,10 @@ fn test_threaded_usage() {
         loop {
             match event_rx.try_recv() {
                 // Event TM received successfully
-                Ok(_) => break,
+                Ok(event) => {
+                    println!("{:x?}", event);
+                    break;
+                }
                 Err(e) => {
                     if let TryRecvError::Disconnected = e {
                         panic!("Event sender disconnected!")