diff --git a/core/main/src/broker/thunder_broker.rs b/core/main/src/broker/thunder_broker.rs index 3cd19a400..3d2e77a25 100644 --- a/core/main/src/broker/thunder_broker.rs +++ b/core/main/src/broker/thunder_broker.rs @@ -382,6 +382,7 @@ mod tests { } } + #[ignore] #[tokio::test] async fn test_thunderbroker_start() { let (tx, mut _rx) = mpsc::channel(1); @@ -393,6 +394,8 @@ mod tests { // Use Broker to connect to it let request = create_broker_request("some_method", ""); + tokio::time::sleep(Duration::from_secs(1)).await; + thndr_broker.sender.send(request).await.unwrap(); let _v = tokio::time::timeout(Duration::from_secs(2), rec.recv()) @@ -472,7 +475,6 @@ mod tests { "key": "value" } }); - ThunderBroker::handle_jsonrpc_response( response.to_string().as_bytes(), BrokerCallback { @@ -495,6 +497,7 @@ mod tests { assert_eq!(key_str, "value"); } + #[ignore] #[tokio::test] async fn test_thunderbroker_subscribe_unsubscribe() { let (tx, mut _rx) = mpsc::channel(1);