Skip to content
Snippets Groups Projects
Commit d39426d5 authored by Jan Tattermusch's avatar Jan Tattermusch
Browse files

change C# service implementations to inherit from a generated base class

parent 10a002d7
No related branches found
No related tags found
No related merge requests found
...@@ -43,14 +43,14 @@ namespace Math ...@@ -43,14 +43,14 @@ namespace Math
/// <summary> /// <summary>
/// Implementation of MathService server /// Implementation of MathService server
/// </summary> /// </summary>
public class MathServiceImpl : Math.IMath public class MathServiceImpl : Math.MathBase
{ {
public Task<DivReply> Div(DivArgs request, ServerCallContext context) public override Task<DivReply> Div(DivArgs request, ServerCallContext context)
{ {
return Task.FromResult(DivInternal(request)); return Task.FromResult(DivInternal(request));
} }
public async Task Fib(FibArgs request, IServerStreamWriter<Num> responseStream, ServerCallContext context) public override async Task Fib(FibArgs request, IServerStreamWriter<Num> responseStream, ServerCallContext context)
{ {
if (request.Limit <= 0) if (request.Limit <= 0)
{ {
...@@ -72,7 +72,7 @@ namespace Math ...@@ -72,7 +72,7 @@ namespace Math
} }
} }
public async Task<Num> Sum(IAsyncStreamReader<Num> requestStream, ServerCallContext context) public override async Task<Num> Sum(IAsyncStreamReader<Num> requestStream, ServerCallContext context)
{ {
long sum = 0; long sum = 0;
await requestStream.ForEachAsync(async num => await requestStream.ForEachAsync(async num =>
...@@ -82,7 +82,7 @@ namespace Math ...@@ -82,7 +82,7 @@ namespace Math
return new Num { Num_ = sum }; return new Num { Num_ = sum };
} }
public async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<DivReply> responseStream, ServerCallContext context) public override async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<DivReply> responseStream, ServerCallContext context)
{ {
await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divArgs))); await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divArgs)));
} }
......
...@@ -51,7 +51,7 @@ namespace Grpc.HealthCheck ...@@ -51,7 +51,7 @@ namespace Grpc.HealthCheck
/// server.AddServiceDefinition(Grpc.Health.V1.Health.BindService(serviceImpl)); /// server.AddServiceDefinition(Grpc.Health.V1.Health.BindService(serviceImpl));
/// </code> /// </code>
/// </summary> /// </summary>
public class HealthServiceImpl : Grpc.Health.V1.Health.IHealth public class HealthServiceImpl : Grpc.Health.V1.Health.HealthBase
{ {
private readonly object myLock = new object(); private readonly object myLock = new object();
private readonly Dictionary<string, HealthCheckResponse.Types.ServingStatus> statusMap = private readonly Dictionary<string, HealthCheckResponse.Types.ServingStatus> statusMap =
...@@ -99,7 +99,7 @@ namespace Grpc.HealthCheck ...@@ -99,7 +99,7 @@ namespace Grpc.HealthCheck
/// <param name="request">The check request.</param> /// <param name="request">The check request.</param>
/// <param name="context">The call context.</param> /// <param name="context">The call context.</param>
/// <returns>The asynchronous response.</returns> /// <returns>The asynchronous response.</returns>
public Task<HealthCheckResponse> Check(HealthCheckRequest request, ServerCallContext context) public override Task<HealthCheckResponse> Check(HealthCheckRequest request, ServerCallContext context)
{ {
lock (myLock) lock (myLock)
{ {
......
...@@ -44,19 +44,19 @@ namespace Grpc.Testing ...@@ -44,19 +44,19 @@ namespace Grpc.Testing
/// <summary> /// <summary>
/// Implementation of BenchmarkService server /// Implementation of BenchmarkService server
/// </summary> /// </summary>
public class BenchmarkServiceImpl : BenchmarkService.IBenchmarkService public class BenchmarkServiceImpl : BenchmarkService.BenchmarkServiceBase
{ {
public BenchmarkServiceImpl() public BenchmarkServiceImpl()
{ {
} }
public Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context) public override Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context)
{ {
var response = new SimpleResponse { Payload = CreateZerosPayload(request.ResponseSize) }; var response = new SimpleResponse { Payload = CreateZerosPayload(request.ResponseSize) };
return Task.FromResult(response); return Task.FromResult(response);
} }
public async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallContext context) public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStream, ServerCallContext context)
{ {
await requestStream.ForEachAsync(async request => await requestStream.ForEachAsync(async request =>
{ {
......
...@@ -45,14 +45,14 @@ namespace Grpc.Testing ...@@ -45,14 +45,14 @@ namespace Grpc.Testing
/// <summary> /// <summary>
/// Implementation of TestService server /// Implementation of TestService server
/// </summary> /// </summary>
public class TestServiceImpl : TestService.ITestService public class TestServiceImpl : TestService.TestServiceBase
{ {
public Task<Empty> EmptyCall(Empty request, ServerCallContext context) public override Task<Empty> EmptyCall(Empty request, ServerCallContext context)
{ {
return Task.FromResult(new Empty()); return Task.FromResult(new Empty());
} }
public async Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context) public override async Task<SimpleResponse> UnaryCall(SimpleRequest request, ServerCallContext context)
{ {
await EnsureEchoMetadataAsync(context); await EnsureEchoMetadataAsync(context);
EnsureEchoStatus(request.ResponseStatus, context); EnsureEchoStatus(request.ResponseStatus, context);
...@@ -61,7 +61,7 @@ namespace Grpc.Testing ...@@ -61,7 +61,7 @@ namespace Grpc.Testing
return response; return response;
} }
public async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context) public override async Task StreamingOutputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
{ {
await EnsureEchoMetadataAsync(context); await EnsureEchoMetadataAsync(context);
EnsureEchoStatus(request.ResponseStatus, context); EnsureEchoStatus(request.ResponseStatus, context);
...@@ -73,7 +73,7 @@ namespace Grpc.Testing ...@@ -73,7 +73,7 @@ namespace Grpc.Testing
} }
} }
public async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> requestStream, ServerCallContext context) public override async Task<StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> requestStream, ServerCallContext context)
{ {
await EnsureEchoMetadataAsync(context); await EnsureEchoMetadataAsync(context);
...@@ -85,7 +85,7 @@ namespace Grpc.Testing ...@@ -85,7 +85,7 @@ namespace Grpc.Testing
return new StreamingInputCallResponse { AggregatedPayloadSize = sum }; return new StreamingInputCallResponse { AggregatedPayloadSize = sum };
} }
public async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context) public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
{ {
await EnsureEchoMetadataAsync(context); await EnsureEchoMetadataAsync(context);
...@@ -100,7 +100,7 @@ namespace Grpc.Testing ...@@ -100,7 +100,7 @@ namespace Grpc.Testing
}); });
} }
public async Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context) public override async Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> responseStream, ServerCallContext context)
{ {
throw new NotImplementedException(); throw new NotImplementedException();
} }
......
...@@ -45,7 +45,7 @@ namespace Grpc.Testing ...@@ -45,7 +45,7 @@ namespace Grpc.Testing
/// <summary> /// <summary>
/// Implementation of WorkerService server /// Implementation of WorkerService server
/// </summary> /// </summary>
public class WorkerServiceImpl : WorkerService.IWorkerService public class WorkerServiceImpl : WorkerService.WorkerServiceBase
{ {
readonly Action stopRequestHandler; readonly Action stopRequestHandler;
...@@ -54,7 +54,7 @@ namespace Grpc.Testing ...@@ -54,7 +54,7 @@ namespace Grpc.Testing
this.stopRequestHandler = GrpcPreconditions.CheckNotNull(stopRequestHandler); this.stopRequestHandler = GrpcPreconditions.CheckNotNull(stopRequestHandler);
} }
public async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWriter<ServerStatus> responseStream, ServerCallContext context) public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWriter<ServerStatus> responseStream, ServerCallContext context)
{ {
GrpcPreconditions.CheckState(await requestStream.MoveNext()); GrpcPreconditions.CheckState(await requestStream.MoveNext());
var serverConfig = requestStream.Current.Setup; var serverConfig = requestStream.Current.Setup;
...@@ -78,7 +78,7 @@ namespace Grpc.Testing ...@@ -78,7 +78,7 @@ namespace Grpc.Testing
await runner.StopAsync(); await runner.StopAsync();
} }
public async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStream, ServerCallContext context) public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStream, ServerCallContext context)
{ {
GrpcPreconditions.CheckState(await requestStream.MoveNext()); GrpcPreconditions.CheckState(await requestStream.MoveNext());
var clientConfig = requestStream.Current.Setup; var clientConfig = requestStream.Current.Setup;
...@@ -100,12 +100,12 @@ namespace Grpc.Testing ...@@ -100,12 +100,12 @@ namespace Grpc.Testing
await runner.StopAsync(); await runner.StopAsync();
} }
public Task<CoreResponse> CoreCount(CoreRequest request, ServerCallContext context) public override Task<CoreResponse> CoreCount(CoreRequest request, ServerCallContext context)
{ {
return Task.FromResult(new CoreResponse { Cores = Environment.ProcessorCount }); return Task.FromResult(new CoreResponse { Cores = Environment.ProcessorCount });
} }
public Task<Void> QuitWorker(Void request, ServerCallContext context) public override Task<Void> QuitWorker(Void request, ServerCallContext context)
{ {
stopRequestHandler(); stopRequestHandler();
return Task.FromResult(new Void()); return Task.FromResult(new Void());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment