Fix test: Reactor should be running during test, not only during communcation

Signed-off-by: Matthias Beyer <mail@beyermatthias.de>

1 files changed, 15 insertions, 24 deletions

diff --git a/lib/src/reactor/gossip/mod.rs b/lib/src/reactor/gossip/mod.rs
index 8676659..9567ccf 100644
--- a/lib/src/reactor/gossip/mod.rs
+++ b/lib/src/reactor/gossip/mod.rs
@@ -229,31 +229,22 @@ mod tests {
         rx.send((GossipRequest::Ping, reply_sender)).unwrap();
 
         let mut pong_received = false;
-        tokio::select! {
-            reply = reply_receiver.recv() => {
-                match reply {
-                    Some(GossipReply::Pong) => {
-                        pong_received = true;
-                        let (reply_sender, mut reply_receiver) = tokio::sync::mpsc::unbounded_channel();
-                        rx.send((GossipRequest::Exit, reply_sender)).unwrap();
-                    }
-                    Some(r) => {
-                        assert!(false, "Expected ReactorReply::Pong, got: {:?}", r);
-                    }
-                    None => {
-                        // nothing
-                    }
-                }
-            },
-
-            reactor_res = reactor.run() => {
-                match reactor_res {
-                    Ok(()) => assert!(false, "Reactor finished before pong was received"),
+        let _ = tokio::spawn(async move {
+            reactor.run().await
+        });
 
-                    Err(e) => {
-                        assert!(false, "Reactor errored: {:?}", e);
-                    }
-                }
+        match reply_receiver.recv().await {
+            Some(GossipReply::Pong) => {
+                pong_received = true;
+                log::trace!("Pong received!");
+                let (reply_sender, mut reply_receiver) = tokio::sync::mpsc::unbounded_channel();
+                rx.send((GossipRequest::Exit, reply_sender)).unwrap();
+            }
+            Some(r) => {
+                assert!(false, "Expected ReactorReply::Pong, got: {:?}", r);
+            }
+            None => {
+                // nothing
             }
         }