From 8f4b2899b8077d156083fe8011ec1423097b7f92 Mon Sep 17 00:00:00 2001
From: Vladimir Shchur <odindafna2006@rambler.ru>
Date: Mon, 27 Jan 2025 09:43:29 -0800
Subject: [PATCH] Fixed compression tests

---
 tests/IntegrationTests/Compression.fs | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/tests/IntegrationTests/Compression.fs b/tests/IntegrationTests/Compression.fs
index 7127b628..ccf1b7c0 100644
--- a/tests/IntegrationTests/Compression.fs
+++ b/tests/IntegrationTests/Compression.fs
@@ -24,7 +24,7 @@ let tests =
 
         let singleOrBatched = if enableBatching then "batched" else "single"
 
-        Log.Debug("Started Send and receive {0} compressed message using '{1}'", singleOrBatched, compressionType)
+        Log.Debug("Started Send and receive {0} compressed message using {1}", singleOrBatched, compressionType)
 
         let client = getClient()
         let topicName = "public/default/topic-" + Guid.NewGuid().ToString("N")
@@ -61,23 +61,26 @@ let tests =
 
         do! Task.WhenAll(producerTask, consumerTask)
 
-        Log.Debug("Finished Send and receive {0} compressed message using '{0}'", singleOrBatched, compressionType)
+        Log.Debug("Finished Send and receive {0} compressed message using {1}", singleOrBatched, compressionType)
     }
 
     let sendMessages enableBatching =
         codecs
-        |> Seq.map (sendReceive enableBatching)
-        |> Task.FromResult
+        |> Array.map (sendReceive enableBatching)
+        |> Task.WhenAll
+
 
     let sendNonBatchedMessages() = sendMessages false
     let sendBatchedMessages() = sendMessages true
 
     testList "Compression" [
         testTask "Send and receive single compressed message using all implemented compression codecs" {
-            do! sendNonBatchedMessages()
+            let! _ = sendNonBatchedMessages()
+            return ()
         }
 
         testTask "Send and receive batched compressed message using all implemented compression codecs" {
-            do! sendBatchedMessages()
+            let! _ = sendBatchedMessages()
+            return ()
         }
     ]