diff options
author | 2016-05-26 19:16:37 -0400 | |
---|---|---|
committer | 2016-05-26 19:16:37 -0400 | |
commit | 5b521d2cbe07a88403d55e1023af92d8c8f56031 (patch) | |
tree | fa2242cb1178920676b58e605c58382ab8917110 /src/csharp/Grpc.Core/Internal/AsyncCallBase.cs | |
parent | 55ebba12055f810b019d8f9c1561e9c0da6b81a8 (diff) | |
parent | 138156abf1954fe7b4407295d4784146a620ef02 (diff) |
Merge pull request #6712 from jtattermusch/csharp_more_completion_queues
C# add support for multiple completion queues in GrpcThreadPool.
Diffstat (limited to 'src/csharp/Grpc.Core/Internal/AsyncCallBase.cs')
-rw-r--r-- | src/csharp/Grpc.Core/Internal/AsyncCallBase.cs | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/csharp/Grpc.Core/Internal/AsyncCallBase.cs b/src/csharp/Grpc.Core/Internal/AsyncCallBase.cs index 5f561daedd..cb8366c216 100644 --- a/src/csharp/Grpc.Core/Internal/AsyncCallBase.cs +++ b/src/csharp/Grpc.Core/Internal/AsyncCallBase.cs @@ -58,7 +58,6 @@ namespace Grpc.Core.Internal readonly Func<TWrite, byte[]> serializer; readonly Func<byte[], TRead> deserializer; - protected readonly GrpcEnvironment environment; protected readonly object myLock = new object(); protected INativeCall call; @@ -78,11 +77,10 @@ namespace Grpc.Core.Internal protected bool initialMetadataSent; protected long streamingWritesCounter; // Number of streaming send operations started so far. - public AsyncCallBase(Func<TWrite, byte[]> serializer, Func<byte[], TRead> deserializer, GrpcEnvironment environment) + public AsyncCallBase(Func<TWrite, byte[]> serializer, Func<byte[], TRead> deserializer) { this.serializer = GrpcPreconditions.CheckNotNull(serializer); this.deserializer = GrpcPreconditions.CheckNotNull(deserializer); - this.environment = GrpcPreconditions.CheckNotNull(environment); } /// <summary> |