aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/csharp/Grpc.Core.Tests
diff options
context:
space:
mode:
authorGravatar Jan Tattermusch <jtattermusch@google.com>2018-09-04 11:44:46 -0700
committerGravatar Jan Tattermusch <jtattermusch@google.com>2018-09-04 11:44:46 -0700
commit1abe2aeb9fe40effca9d66a9bd02a65821913199 (patch)
tree5e42589b0a57535c2deb2bab5503e128e76cef67 /src/csharp/Grpc.Core.Tests
parentcd74b357e14ecb961ec7da681448cbe506058d7d (diff)
c#: expose TryWaitForStateChangedAsync
Diffstat (limited to 'src/csharp/Grpc.Core.Tests')
-rw-r--r--src/csharp/Grpc.Core.Tests/ChannelConnectivityTest.cs18
1 files changed, 18 insertions, 0 deletions
diff --git a/src/csharp/Grpc.Core.Tests/ChannelConnectivityTest.cs b/src/csharp/Grpc.Core.Tests/ChannelConnectivityTest.cs
index a43040f01a..b4b3b2d5ac 100644
--- a/src/csharp/Grpc.Core.Tests/ChannelConnectivityTest.cs
+++ b/src/csharp/Grpc.Core.Tests/ChannelConnectivityTest.cs
@@ -74,6 +74,24 @@ namespace Grpc.Core.Tests
}
[Test]
+ public async Task Channel_TryWaitForStateChangedAsync()
+ {
+ helper.UnaryHandler = new UnaryServerMethod<string, string>((request, context) =>
+ {
+ return Task.FromResult(request);
+ });
+
+ Assert.IsFalse(await channel.TryWaitForStateChangedAsync(channel.State, DateTime.UtcNow.AddMilliseconds(10)));
+
+ var stateChangedTask = channel.TryWaitForStateChangedAsync(channel.State);
+
+ await Calls.AsyncUnaryCall(helper.CreateUnaryCall(), "abc");
+
+ Assert.IsTrue(await stateChangedTask);
+ Assert.AreEqual(ChannelState.Ready, channel.State);
+ }
+
+ [Test]
public async Task Channel_ConnectAsync()
{
await channel.ConnectAsync();