|  | @@ -12,45 +12,45 @@ namespace grpc.testing {
 | 
	
		
			
				|  |  |    {
 | 
	
		
			
				|  |  |      static readonly string __ServiceName = "grpc.testing.TestService";
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Marshaller<Empty> __Marshaller_Empty = Marshallers.Create((arg) => arg.ToByteArray(), Empty.ParseFrom);
 | 
	
		
			
				|  |  | -    static readonly Marshaller<SimpleRequest> __Marshaller_SimpleRequest = Marshallers.Create((arg) => arg.ToByteArray(), SimpleRequest.ParseFrom);
 | 
	
		
			
				|  |  | -    static readonly Marshaller<SimpleResponse> __Marshaller_SimpleResponse = Marshallers.Create((arg) => arg.ToByteArray(), SimpleResponse.ParseFrom);
 | 
	
		
			
				|  |  | -    static readonly Marshaller<StreamingOutputCallRequest> __Marshaller_StreamingOutputCallRequest = Marshallers.Create((arg) => arg.ToByteArray(), StreamingOutputCallRequest.ParseFrom);
 | 
	
		
			
				|  |  | -    static readonly Marshaller<StreamingOutputCallResponse> __Marshaller_StreamingOutputCallResponse = Marshallers.Create((arg) => arg.ToByteArray(), StreamingOutputCallResponse.ParseFrom);
 | 
	
		
			
				|  |  | -    static readonly Marshaller<StreamingInputCallRequest> __Marshaller_StreamingInputCallRequest = Marshallers.Create((arg) => arg.ToByteArray(), StreamingInputCallRequest.ParseFrom);
 | 
	
		
			
				|  |  | -    static readonly Marshaller<StreamingInputCallResponse> __Marshaller_StreamingInputCallResponse = Marshallers.Create((arg) => arg.ToByteArray(), StreamingInputCallResponse.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.Empty> __Marshaller_Empty = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.Empty.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.SimpleRequest> __Marshaller_SimpleRequest = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.SimpleRequest.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.SimpleResponse> __Marshaller_SimpleResponse = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.SimpleResponse.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.StreamingOutputCallRequest> __Marshaller_StreamingOutputCallRequest = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.StreamingOutputCallRequest.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.StreamingOutputCallResponse> __Marshaller_StreamingOutputCallResponse = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.StreamingOutputCallResponse.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.StreamingInputCallRequest> __Marshaller_StreamingInputCallRequest = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.StreamingInputCallRequest.ParseFrom);
 | 
	
		
			
				|  |  | +    static readonly Marshaller<global::grpc.testing.StreamingInputCallResponse> __Marshaller_StreamingInputCallResponse = Marshallers.Create((arg) => arg.ToByteArray(), global::grpc.testing.StreamingInputCallResponse.ParseFrom);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Method<Empty, Empty> __Method_EmptyCall = new Method<Empty, Empty>(
 | 
	
		
			
				|  |  | +    static readonly Method<global::grpc.testing.Empty, global::grpc.testing.Empty> __Method_EmptyCall = new Method<global::grpc.testing.Empty, global::grpc.testing.Empty>(
 | 
	
		
			
				|  |  |          MethodType.Unary,
 | 
	
		
			
				|  |  |          "EmptyCall",
 | 
	
		
			
				|  |  |          __Marshaller_Empty,
 | 
	
		
			
				|  |  |          __Marshaller_Empty);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Method<SimpleRequest, SimpleResponse> __Method_UnaryCall = new Method<SimpleRequest, SimpleResponse>(
 | 
	
		
			
				|  |  | +    static readonly Method<global::grpc.testing.SimpleRequest, global::grpc.testing.SimpleResponse> __Method_UnaryCall = new Method<global::grpc.testing.SimpleRequest, global::grpc.testing.SimpleResponse>(
 | 
	
		
			
				|  |  |          MethodType.Unary,
 | 
	
		
			
				|  |  |          "UnaryCall",
 | 
	
		
			
				|  |  |          __Marshaller_SimpleRequest,
 | 
	
		
			
				|  |  |          __Marshaller_SimpleResponse);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Method<StreamingOutputCallRequest, StreamingOutputCallResponse> __Method_StreamingOutputCall = new Method<StreamingOutputCallRequest, StreamingOutputCallResponse>(
 | 
	
		
			
				|  |  | +    static readonly Method<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> __Method_StreamingOutputCall = new Method<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse>(
 | 
	
		
			
				|  |  |          MethodType.ServerStreaming,
 | 
	
		
			
				|  |  |          "StreamingOutputCall",
 | 
	
		
			
				|  |  |          __Marshaller_StreamingOutputCallRequest,
 | 
	
		
			
				|  |  |          __Marshaller_StreamingOutputCallResponse);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Method<StreamingInputCallRequest, StreamingInputCallResponse> __Method_StreamingInputCall = new Method<StreamingInputCallRequest, StreamingInputCallResponse>(
 | 
	
		
			
				|  |  | +    static readonly Method<global::grpc.testing.StreamingInputCallRequest, global::grpc.testing.StreamingInputCallResponse> __Method_StreamingInputCall = new Method<global::grpc.testing.StreamingInputCallRequest, global::grpc.testing.StreamingInputCallResponse>(
 | 
	
		
			
				|  |  |          MethodType.ClientStreaming,
 | 
	
		
			
				|  |  |          "StreamingInputCall",
 | 
	
		
			
				|  |  |          __Marshaller_StreamingInputCallRequest,
 | 
	
		
			
				|  |  |          __Marshaller_StreamingInputCallResponse);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Method<StreamingOutputCallRequest, StreamingOutputCallResponse> __Method_FullDuplexCall = new Method<StreamingOutputCallRequest, StreamingOutputCallResponse>(
 | 
	
		
			
				|  |  | +    static readonly Method<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> __Method_FullDuplexCall = new Method<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse>(
 | 
	
		
			
				|  |  |          MethodType.DuplexStreaming,
 | 
	
		
			
				|  |  |          "FullDuplexCall",
 | 
	
		
			
				|  |  |          __Marshaller_StreamingOutputCallRequest,
 | 
	
		
			
				|  |  |          __Marshaller_StreamingOutputCallResponse);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    static readonly Method<StreamingOutputCallRequest, StreamingOutputCallResponse> __Method_HalfDuplexCall = new Method<StreamingOutputCallRequest, StreamingOutputCallResponse>(
 | 
	
		
			
				|  |  | +    static readonly Method<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> __Method_HalfDuplexCall = new Method<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse>(
 | 
	
		
			
				|  |  |          MethodType.DuplexStreaming,
 | 
	
		
			
				|  |  |          "HalfDuplexCall",
 | 
	
		
			
				|  |  |          __Marshaller_StreamingOutputCallRequest,
 | 
	
	
		
			
				|  | @@ -59,25 +59,25 @@ namespace grpc.testing {
 | 
	
		
			
				|  |  |      // client-side stub interface
 | 
	
		
			
				|  |  |      public interface ITestServiceClient
 | 
	
		
			
				|  |  |      {
 | 
	
		
			
				|  |  | -      Empty EmptyCall(Empty request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      Task<Empty> EmptyCallAsync(Empty request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      SimpleResponse UnaryCall(SimpleRequest request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      Task<SimpleResponse> UnaryCallAsync(SimpleRequest request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      AsyncServerStreamingCall<StreamingOutputCallResponse> StreamingOutputCall(StreamingOutputCallRequest request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      AsyncClientStreamingCall<StreamingInputCallRequest, StreamingInputCallResponse> StreamingInputCall(CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      AsyncDuplexStreamingCall<StreamingOutputCallRequest, StreamingOutputCallResponse> FullDuplexCall(CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | -      AsyncDuplexStreamingCall<StreamingOutputCallRequest, StreamingOutputCallResponse> HalfDuplexCall(CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      global::grpc.testing.Empty EmptyCall(global::grpc.testing.Empty request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      Task<global::grpc.testing.Empty> EmptyCallAsync(global::grpc.testing.Empty request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      global::grpc.testing.SimpleResponse UnaryCall(global::grpc.testing.SimpleRequest request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      Task<global::grpc.testing.SimpleResponse> UnaryCallAsync(global::grpc.testing.SimpleRequest request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      AsyncServerStreamingCall<global::grpc.testing.StreamingOutputCallResponse> StreamingOutputCall(global::grpc.testing.StreamingOutputCallRequest request, CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      AsyncClientStreamingCall<global::grpc.testing.StreamingInputCallRequest, global::grpc.testing.StreamingInputCallResponse> StreamingInputCall(CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      AsyncDuplexStreamingCall<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> FullDuplexCall(CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  | +      AsyncDuplexStreamingCall<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> HalfDuplexCall(CancellationToken token = default(CancellationToken));
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      // server-side interface
 | 
	
		
			
				|  |  |      public interface ITestService
 | 
	
		
			
				|  |  |      {
 | 
	
		
			
				|  |  | -      Task<Empty> EmptyCall(ServerCallContext context, Empty request);
 | 
	
		
			
				|  |  | -      Task<SimpleResponse> UnaryCall(ServerCallContext context, SimpleRequest request);
 | 
	
		
			
				|  |  | -      Task StreamingOutputCall(ServerCallContext context, StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream);
 | 
	
		
			
				|  |  | -      Task<StreamingInputCallResponse> StreamingInputCall(ServerCallContext context, IAsyncStreamReader<StreamingInputCallRequest> requestStream);
 | 
	
		
			
				|  |  | -      Task FullDuplexCall(ServerCallContext context, IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream);
 | 
	
		
			
				|  |  | -      Task HalfDuplexCall(ServerCallContext context, IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream);
 | 
	
		
			
				|  |  | +      Task<global::grpc.testing.Empty> EmptyCall(ServerCallContext context, global::grpc.testing.Empty request);
 | 
	
		
			
				|  |  | +      Task<global::grpc.testing.SimpleResponse> UnaryCall(ServerCallContext context, global::grpc.testing.SimpleRequest request);
 | 
	
		
			
				|  |  | +      Task StreamingOutputCall(ServerCallContext context, global::grpc.testing.StreamingOutputCallRequest request, IServerStreamWriter<global::grpc.testing.StreamingOutputCallResponse> responseStream);
 | 
	
		
			
				|  |  | +      Task<global::grpc.testing.StreamingInputCallResponse> StreamingInputCall(ServerCallContext context, IAsyncStreamReader<global::grpc.testing.StreamingInputCallRequest> requestStream);
 | 
	
		
			
				|  |  | +      Task FullDuplexCall(ServerCallContext context, IAsyncStreamReader<global::grpc.testing.StreamingOutputCallRequest> requestStream, IServerStreamWriter<global::grpc.testing.StreamingOutputCallResponse> responseStream);
 | 
	
		
			
				|  |  | +      Task HalfDuplexCall(ServerCallContext context, IAsyncStreamReader<global::grpc.testing.StreamingOutputCallRequest> requestStream, IServerStreamWriter<global::grpc.testing.StreamingOutputCallResponse> responseStream);
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      // client stub
 | 
	
	
		
			
				|  | @@ -89,42 +89,42 @@ namespace grpc.testing {
 | 
	
		
			
				|  |  |        public TestServiceClient(Channel channel, StubConfiguration config) : base(channel, config)
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public Empty EmptyCall(Empty request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public global::grpc.testing.Empty EmptyCall(global::grpc.testing.Empty request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_EmptyCall);
 | 
	
		
			
				|  |  |          return Calls.BlockingUnaryCall(call, request, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public Task<Empty> EmptyCallAsync(Empty request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public Task<global::grpc.testing.Empty> EmptyCallAsync(global::grpc.testing.Empty request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_EmptyCall);
 | 
	
		
			
				|  |  |          return Calls.AsyncUnaryCall(call, request, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public SimpleResponse UnaryCall(SimpleRequest request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public global::grpc.testing.SimpleResponse UnaryCall(global::grpc.testing.SimpleRequest request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_UnaryCall);
 | 
	
		
			
				|  |  |          return Calls.BlockingUnaryCall(call, request, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public Task<SimpleResponse> UnaryCallAsync(SimpleRequest request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public Task<global::grpc.testing.SimpleResponse> UnaryCallAsync(global::grpc.testing.SimpleRequest request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_UnaryCall);
 | 
	
		
			
				|  |  |          return Calls.AsyncUnaryCall(call, request, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public AsyncServerStreamingCall<StreamingOutputCallResponse> StreamingOutputCall(StreamingOutputCallRequest request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public AsyncServerStreamingCall<global::grpc.testing.StreamingOutputCallResponse> StreamingOutputCall(global::grpc.testing.StreamingOutputCallRequest request, CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_StreamingOutputCall);
 | 
	
		
			
				|  |  |          return Calls.AsyncServerStreamingCall(call, request, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public AsyncClientStreamingCall<StreamingInputCallRequest, StreamingInputCallResponse> StreamingInputCall(CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public AsyncClientStreamingCall<global::grpc.testing.StreamingInputCallRequest, global::grpc.testing.StreamingInputCallResponse> StreamingInputCall(CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_StreamingInputCall);
 | 
	
		
			
				|  |  |          return Calls.AsyncClientStreamingCall(call, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public AsyncDuplexStreamingCall<StreamingOutputCallRequest, StreamingOutputCallResponse> FullDuplexCall(CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public AsyncDuplexStreamingCall<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> FullDuplexCall(CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_FullDuplexCall);
 | 
	
		
			
				|  |  |          return Calls.AsyncDuplexStreamingCall(call, token);
 | 
	
		
			
				|  |  |        }
 | 
	
		
			
				|  |  | -      public AsyncDuplexStreamingCall<StreamingOutputCallRequest, StreamingOutputCallResponse> HalfDuplexCall(CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  | +      public AsyncDuplexStreamingCall<global::grpc.testing.StreamingOutputCallRequest, global::grpc.testing.StreamingOutputCallResponse> HalfDuplexCall(CancellationToken token = default(CancellationToken))
 | 
	
		
			
				|  |  |        {
 | 
	
		
			
				|  |  |          var call = CreateCall(__ServiceName, __Method_HalfDuplexCall);
 | 
	
		
			
				|  |  |          return Calls.AsyncDuplexStreamingCall(call, token);
 |