* No need for random data, just different data.

Author: lukebakken

projects/Test/Integration/TestAsyncConsumer.cs

@@ -58,7 +58,7 @@ public async Task TestBasicRoundtripConcurrent()
             QueueDeclareOk q = await _channel.QueueDeclareAsync();
 
             const int length = 4096;
-            (byte[] body1, byte[] body2) = await GenerateTwoBodies(length);
+            (byte[] body1, byte[] body2) = GenerateTwoBodies(length);
 
             await _channel.BasicPublishAsync("", q.QueueName, body1);
             await _channel.BasicPublishAsync("", q.QueueName, body2);
@@ -152,7 +152,7 @@ public async Task TestBasicRoundtripConcurrentManyMessages()
             const int length = 512;
             string queueName = GenerateQueueName();
 
-            (byte[] body1, byte[] body2) = await GenerateTwoBodies(length);
+            (byte[] body1, byte[] body2) = GenerateTwoBodies(length);
 
             var publish1SyncSource = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
             var publish2SyncSource = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
@@ -693,24 +693,10 @@ private static bool ByteArraysEqual(ReadOnlySpan<byte> a1, ReadOnlySpan<byte> a2
             return a1.SequenceEqual(a2);
         }
 
-        private static async Task<(byte[] body1, byte[] body2)> GenerateTwoBodies(ushort length)
+        private static (byte[] body1, byte[] body2) GenerateTwoBodies(ushort length)
         {
-            DateTime start = DateTime.Now;
-            byte[] body1 = GetRandomBody(length);
-            byte[] body2 = GetRandomBody(length);
-            while (ByteArraysEqual(body1, body2))
-            {
-                body2 = GetRandomBody(length);
-                if (DateTime.Now - start > ShortSpan)
-                {
-                    Assert.Fail($"could not generate two different random sets of data within {ShortSpan}");
-                }
-                else
-                {
-                    await Task.Delay(500);
-                }
-            }
-
+            byte[] body1 = _encoding.GetBytes(new string('x', length));
+            byte[] body2 = _encoding.GetBytes(new string('y', length));
             return (body1, body2);
         }