diff --git a/services/commtest/tests/blob_performance_test.rs b/services/commtest/tests/blob_performance_test.rs --- a/services/commtest/tests/blob_performance_test.rs +++ b/services/commtest/tests/blob_performance_test.rs @@ -46,6 +46,21 @@ // PUT rt.block_on(async { println!("performing PUT operations"); + let mut handlers = vec![]; + for item in &blob_data { + let item_cloned = item.clone(); + let mut client_cloned = client.clone(); + handlers.push(tokio::spawn(async move { + println!("--- PUT {}", item_cloned.holder); + let data_exists: bool = + put::run(&mut client_cloned, &item_cloned).await.unwrap(); + assert!(!data_exists, "test data should not exist"); + })); + } + + for handler in handlers { + handler.await.unwrap(); + } }); // GET