diff options
author | 2015-08-05 00:44:29 -0700 | |
---|---|---|
committer | 2015-08-05 14:32:11 -0700 | |
commit | cc97fed6d8c9569ed2a93388e8baaabfcc68c0a2 (patch) | |
tree | be1bd3497352020ac04aaf8bc26a4a29c4b26cd6 /src/csharp/Grpc.Core/Calls.cs | |
parent | 641cb1be9f2b2b55a68460b9e23e9a30e7d3a3f7 (diff) |
regenerated code
Diffstat (limited to 'src/csharp/Grpc.Core/Calls.cs')
-rw-r--r-- | src/csharp/Grpc.Core/Calls.cs | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/csharp/Grpc.Core/Calls.cs b/src/csharp/Grpc.Core/Calls.cs index ef6636587e..f975bcde22 100644 --- a/src/csharp/Grpc.Core/Calls.cs +++ b/src/csharp/Grpc.Core/Calls.cs @@ -47,8 +47,8 @@ namespace Grpc.Core where TRequest : class where TResponse : class { - var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Name, null, call.Context, - call.RequestMarshaller.Serializer, call.ResponseMarshaller.Deserializer); + var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Method.FullName, call.Host, call.Context, + call.Method.RequestMarshaller.Serializer, call.Method.ResponseMarshaller.Deserializer); // TODO(jtattermusch): this gives a race that cancellation can be requested before the call even starts. RegisterCancellationCallback(asyncCall, call.Context.CancellationToken); return asyncCall.UnaryCall(req); @@ -58,8 +58,8 @@ namespace Grpc.Core where TRequest : class where TResponse : class { - var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Name, null, call.Context, - call.RequestMarshaller.Serializer, call.ResponseMarshaller.Deserializer); + var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Method.FullName, call.Host, call.Context, + call.Method.RequestMarshaller.Serializer, call.Method.ResponseMarshaller.Deserializer); var asyncResult = asyncCall.UnaryCallAsync(req); RegisterCancellationCallback(asyncCall, call.Context.CancellationToken); return new AsyncUnaryCall<TResponse>(asyncResult, asyncCall.GetStatus, asyncCall.GetTrailers, asyncCall.Cancel); @@ -69,8 +69,8 @@ namespace Grpc.Core where TRequest : class where TResponse : class { - var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Name, null, call.Context, - call.RequestMarshaller.Serializer, call.ResponseMarshaller.Deserializer); + var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Method.FullName, call.Host, call.Context, + call.Method.RequestMarshaller.Serializer, call.Method.ResponseMarshaller.Deserializer); asyncCall.StartServerStreamingCall(req); RegisterCancellationCallback(asyncCall, call.Context.CancellationToken); var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); @@ -81,8 +81,8 @@ namespace Grpc.Core where TRequest : class where TResponse : class { - var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Name, null, call.Context, - call.RequestMarshaller.Serializer, call.ResponseMarshaller.Deserializer); + var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Method.FullName, call.Host, call.Context, + call.Method.RequestMarshaller.Serializer, call.Method.ResponseMarshaller.Deserializer); var resultTask = asyncCall.ClientStreamingCallAsync(); RegisterCancellationCallback(asyncCall, call.Context.CancellationToken); var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); @@ -93,8 +93,8 @@ namespace Grpc.Core where TRequest : class where TResponse : class { - var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Name, null, call.Context, - call.RequestMarshaller.Serializer, call.ResponseMarshaller.Deserializer); + var asyncCall = new AsyncCall<TRequest, TResponse>(call.Channel, call.Method.FullName, call.Host, call.Context, + call.Method.RequestMarshaller.Serializer, call.Method.ResponseMarshaller.Deserializer); asyncCall.StartDuplexStreamingCall(); RegisterCancellationCallback(asyncCall, call.Context.CancellationToken); var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); |