Increase timeouts in tests

Author: sierpinskid

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

@@ -126,7 +126,7 @@ protected Task<StreamChatClient> GetConnectedOtherClientAsync()
         /// <summary>
         /// Use this if state update depends on receiving WS event that might come after the REST call was completed
         /// </summary>
-        protected static async Task WaitWhileTrueAsync(Func<bool> condition, int maxIterations = 500)
+        protected static async Task WaitWhileTrueAsync(Func<bool> condition, int maxIterations = 500, int maxSeconds = 500)
         {
             var sw = new Stopwatch();
             sw.Start();
@@ -138,14 +138,16 @@ protected static async Task WaitWhileTrueAsync(Func<bool> condition, int maxIter
                     return;
                 }
 
-                if (sw.Elapsed.Seconds > 60)
+                if (sw.Elapsed.Seconds > maxSeconds)
                 {
-                    return;
+                    throw new TimeoutException("Timeout while waiting for condition");
                 }
 
                 var delay = (int)Math.Max(1, Math.Min(400, Math.Pow(2, i)));
                 await Task.Delay(delay);
             }
+
+            throw new TimeoutException("Timeout while waiting for condition");
         }
 
         protected static async Task WaitWhileFalseAsync(Func<bool> condition, int maxIterations = 500, int maxSeconds = 500)
@@ -162,15 +164,17 @@ protected static async Task WaitWhileFalseAsync(Func<bool> condition, int maxIte
 
                 if (sw.Elapsed.Seconds > maxSeconds)
                 {
-                    return;
+                    throw new TimeoutException("Timeout while waiting for condition");
                 }
 
                 var delay = (int)Math.Max(1, Math.Min(400, Math.Pow(2, i)));
                 await Task.Delay(delay);
             }
+            
+            throw new TimeoutException("Timeout while waiting for condition");
         }
 
-        protected static async Task WaitWithTimeoutAsync(Task task, int maxSeconds, string exceptionMsg)
+        protected static async Task WaitWithTimeoutAsync(Task task, string exceptionMsg, int maxSeconds = 300)
         {
             if (await Task.WhenAny(task, Task.Delay(maxSeconds * 1000)) != task)
             {

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

@@ -112,7 +112,7 @@ void OnMessageReceived(IStreamChannel channel2, IStreamMessage message)
             await WaitWhileTrueAsync(() => channel.Members.All(m => m.User != otherUser));
             Assert.NotNull(channel.Members.FirstOrDefault(member => member.User == otherUser));
 
-            await WaitWithTimeoutAsync(tcs.Task, 5, $"Event {nameof(channel.MessageReceived)} was not received");
+            await WaitWithTimeoutAsync(tcs.Task, $"Event {nameof(channel.MessageReceived)} was not received");
 
             channel.MessageReceived -= OnMessageReceived;
         }

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

@@ -378,7 +378,7 @@ void OnChannelUpdated(IStreamChannel channel2)
 
             await channel.UpdateOverwriteAsync(new StreamUpdateOverwriteChannelRequest(channel));
 
-            await WaitWithTimeoutAsync(cts.Task, 5, $"Channel {nameof(channel.Updated)} event was not received");
+            await WaitWithTimeoutAsync(cts.Task, $"Channel {nameof(channel.Updated)} event was not received");
 
             channel.Updated -= OnChannelUpdated;
 
@@ -431,7 +431,7 @@ void OnChannelUpdated(IStreamChannel channel2)
 
             await channel.UpdateOverwriteAsync(new StreamUpdateOverwriteChannelRequest());
 
-            await WaitWithTimeoutAsync(cts.Task, 5, $"Channel {nameof(channel.Updated)} event was not received");
+            await WaitWithTimeoutAsync(cts.Task, $"Channel {nameof(channel.Updated)} event was not received");
 
             channel.Updated -= OnChannelUpdated;
 
@@ -489,7 +489,7 @@ await channel.UpdateOverwriteAsync(new StreamUpdateOverwriteChannelRequest
                 }
             });
 
-            await WaitWithTimeoutAsync(cts.Task, 5, $"Channel {nameof(channel.Updated)} event was not received");
+            await WaitWithTimeoutAsync(cts.Task, $"Channel {nameof(channel.Updated)} event was not received");
 
             channel.Updated -= OnChannelUpdated;
 
@@ -576,8 +576,7 @@ void OnChannelUpdated(IStreamChannel channel2)
 
             await channel.InviteMembersAsync(OtherUserId);
 
-            await WaitWithTimeoutAsync(taskCompletionSource.Task, maxSeconds: 3,
-                $"Event {nameof(channel.Updated)} was not received");
+            await WaitWithTimeoutAsync(taskCompletionSource.Task, $"Event {nameof(channel.Updated)} was not received");
 
             channel.Updated -= OnChannelUpdated;
         }