test ci

bindings_ffi/src/mls.rs

@@ -1917,12 +1917,12 @@ mod tests {
         assert!(stream.is_closed());
     }
 
-    #[tokio::test(flavor = "multi_thread", worker_threads = 5)]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_message_streaming() {
         let amal = new_test_client().await;
         let bola = new_test_client().await;
 
-        let group = amal
+        let group: Arc<FfiGroup> = amal
             .conversations()
             .create_group(
                 vec![bola.account_address.clone()],
@@ -1936,12 +1936,14 @@ mod tests {
         stream_closer.wait_for_ready().await;
 
         group.send("hello".as_bytes().to_vec()).await.unwrap();
+        println!("WAITING FOR HELLO");
         stream_callback.wait_for_delivery().await;
         group.send("goodbye".as_bytes().to_vec()).await.unwrap();
+        println!("WAITING GOODBYE");
         stream_callback.wait_for_delivery().await;
 
         assert_eq!(stream_callback.message_count(), 2);
-
+        println!("WAITING FOR STREAM TO END");
         stream_closer.end_and_wait().await.unwrap();
     }