Fix test

Author: drogus

crates/core/src/subscription/module_subscription_actor.rs

@@ -325,13 +325,18 @@ mod tests {
             timer: None,
         });
 
-        let subscriptions = module_subscriptions.subscriptions.read();
-        module_subscriptions.blocking_broadcast_event(Some(&sender), &subscriptions, event);
-        drop(subscriptions);
+        runtime.spawn_blocking(move || {
+            let subscriptions = module_subscriptions.subscriptions.read();
+            module_subscriptions.blocking_broadcast_event(Some(&sender), &subscriptions, event);
+        });
 
         runtime.block_on(async move {
-            rx0.recv().await.expect("Expected at least one message");
-            rx1.recv().await.expect("Expected at least one message");
+            tokio::time::timeout(Duration::from_millis(10), async move {
+                rx0.recv().await.expect("Expected at least one message");
+                rx1.recv().await.expect("Expected at least one message");
+            })
+            .await
+            .unwrap();
         });
 
         Ok(())