Add waiting for the final result + make tests resilient to concurrent tests execution

Author: sierpinskid

Assets/Plugins/StreamChat/Tests/StatefulClient/ChannelsQueryFiltersTests.cs

@@ -160,7 +160,7 @@ private async Task When_query_channel_with_member_name_autocomplete_filter_expec
             await channel1.AddMembersAsync(hideHistory: default, optionalMessage: default, userAnna);
             await channel2.AddMembersAsync(hideHistory: default, optionalMessage: default, userDaniel);
             await channel3.AddMembersAsync(hideHistory: default, optionalMessage: default, userJonathan);
-            
+
             // The search filter for MemberUserName relies on the `read-channel-members` permissions being enabled.
             // For channel type `Messaging` you can only view other members if you're a member yourself
             await channel2.AddMembersAsync(hideHistory: default, optionalMessage: default, Client.LocalUserData.User);
@@ -173,7 +173,7 @@ private async Task When_query_channel_with_member_name_autocomplete_filter_expec
             var channels2 = (await Client.QueryChannelsAsync(filters2, _sortByCreatedAtAscending)).ToArray();
             Assert.Contains(channel2, channels2);
         }
-        
+
         [UnityTest]
         public IEnumerator When_query_channel_with_members_count_filter_expect_valid_results()
             => ConnectAndExecute(When_query_channel_with_members_count_filter_expect_valid_results_Async);
@@ -183,7 +183,7 @@ private async Task When_query_channel_with_members_count_filter_expect_valid_res
             var channel1 = await CreateUniqueTempChannelAsync();
             var channel2 = await CreateUniqueTempChannelAsync();
             var channel3 = await CreateUniqueTempChannelAsync();
-            
+
             var userAnna = await CreateUniqueTempUserAsync("Anna");
             var userDaniel = await CreateUniqueTempUserAsync("Daniel");
             var userJonathan = await CreateUniqueTempUserAsync("Jonathan");
@@ -197,14 +197,15 @@ private async Task When_query_channel_with_members_count_filter_expect_valid_res
                 ChannelFilter.MembersCount.EqualsTo(3),
             };
 
-            var channels = (await Client.QueryChannelsAsync(filters, _sortByCreatedAtAscending)).ToArray();
+            var channels = (await TryAsync(() => Client.QueryChannelsAsync(filters, _sortByCreatedAtAscending),
+                channels => channels.All(c => c.MemberCount == 3))).ToArray();
             Assert.IsNull(channels.FirstOrDefault(c => c == channel1));
             Assert.Contains(channel2, channels);
             Assert.IsNull(channels.FirstOrDefault(c => c == channel3));
-            
+
             Assert.IsTrue(channels.All(c => c.MemberCount == 3));
         }
-        
+
         [UnityTest]
         public IEnumerator When_query_channel_by_created_at_filter_expect_valid_results()
             => ConnectAndExecute(When_query_channel_by_created_at_filter_expect_valid_results_Async);
@@ -214,16 +215,16 @@ private async Task When_query_channel_by_created_at_filter_expect_valid_results_
             var channel1 = await CreateUniqueTempChannelAsync();
             var channel2 = await CreateUniqueTempChannelAsync();
             var channel3 = await CreateUniqueTempChannelAsync();
+            var allChannels = new [] { channel1, channel2, channel3 };  
 
             var filters = new IFieldFilterRule[]
             {
-                ChannelFilter.CreatedAt.GreaterThanOrEquals(DateTime.Now.AddMinutes(-5)),
+                ChannelFilter.CreatedAt.GreaterThanOrEquals(DateTime.UtcNow.AddMinutes(-5)),
             };
 
-            var channels = (await Client.QueryChannelsAsync(filters, _sortByCreatedAtAscending)).ToArray();
-            Assert.Contains(channel1, channels);
-            Assert.Contains(channel2, channels); 
-            Assert.Contains(channel3, channels);
+		  var channels = await TryAsync(() => Client.QueryChannelsAsync(filters, _sortByCreatedAtAscending),
+                channels => allChannels.All(channels.Contains));
+            Assert.IsTrue(allChannels.All(channels.Contains));
         }
 
         private readonly ChannelSortObject _sortByCreatedAtAscending