diff options
author | Jan Tattermusch <jtattermusch@google.com> | 2018-09-04 11:44:46 -0700 |
---|---|---|
committer | Jan Tattermusch <jtattermusch@google.com> | 2018-09-04 11:44:46 -0700 |
commit | 1abe2aeb9fe40effca9d66a9bd02a65821913199 (patch) | |
tree | 5e42589b0a57535c2deb2bab5503e128e76cef67 /src/csharp/Grpc.Core.Tests | |
parent | cd74b357e14ecb961ec7da681448cbe506058d7d (diff) |
c#: expose TryWaitForStateChangedAsync
Diffstat (limited to 'src/csharp/Grpc.Core.Tests')
-rw-r--r-- | src/csharp/Grpc.Core.Tests/ChannelConnectivityTest.cs | 18 |
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(); |