From 32d196f1b1859d6a0eaa906f65a82c42ad1b2c87 Mon Sep 17 00:00:00 2001
From: Jan Tattermusch <jtattermusch@google.com>
Date: Thu, 5 Oct 2017 16:34:00 +0200
Subject: [PATCH] remove delays in tests

---
 src/csharp/Grpc.Core.Tests/CallCancellationTest.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/csharp/Grpc.Core.Tests/CallCancellationTest.cs b/src/csharp/Grpc.Core.Tests/CallCancellationTest.cs
index e4e859d5160..e040f52380a 100644
--- a/src/csharp/Grpc.Core.Tests/CallCancellationTest.cs
+++ b/src/csharp/Grpc.Core.Tests/CallCancellationTest.cs
@@ -129,7 +129,6 @@ namespace Grpc.Core.Tests
             {
                 var cts = new CancellationTokenSource();
                 var moveNextTask = requestStream.MoveNext(cts.Token);
-                await Task.Delay(100);
                 cts.Cancel();
                 await moveNextTask;
                 return "";
@@ -154,8 +153,10 @@ namespace Grpc.Core.Tests
             helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) =>
             {
                 await responseStream.WriteAsync("abc");
-                await Task.Delay(10000);
-                await responseStream.WriteAsync("def");
+                while (!context.CancellationToken.IsCancellationRequested)
+                {
+                    await Task.Delay(10);
+                }
             });
 
             var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), "");
@@ -164,7 +165,6 @@ namespace Grpc.Core.Tests
 
             var cts = new CancellationTokenSource();
             var moveNextTask = call.ResponseStream.MoveNext(cts.Token);
-            await Task.Delay(100);
             cts.Cancel();
 
             try