diff --git a/test/Tester/GrainCallFilterTests.cs b/test/Tester/GrainCallFilterTests.cs
index 837630ffb1..f96d564609 100644
--- a/test/Tester/GrainCallFilterTests.cs
+++ b/test/Tester/GrainCallFilterTests.cs
@@ -204,13 +204,14 @@ public async Task GrainCallFilter_Incoming_Stream_Test()
             // The intercepted grain should double the value passed to the stream.
             const int testValue = 43;
             await stream.OnNextAsync(testValue);
-            var cts = new CancellationTokenSource(1000);
+            using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));
             int actual = 0;
             while (!cts.IsCancellationRequested)
             {
                 actual = await grain.GetLastStreamValue();
                 if (actual != 0) break;
             }
+            
             Assert.Equal(testValue * 2, actual);
         }