migrate code to single client-side class

pull/5928/head
Jan Tattermusch 9 years ago
parent d9495abc3c
commit 809148d6c5
  1. 2
      src/csharp/Grpc.Examples.MathClient/MathClient.cs
  2. 12
      src/csharp/Grpc.Examples/MathExamples.cs
  3. 2
      src/csharp/Grpc.HealthCheck.Tests/HealthClientServerTest.cs
  4. 2
      src/csharp/Grpc.IntegrationTesting/ClientRunners.cs
  5. 24
      src/csharp/Grpc.IntegrationTesting/InteropClient.cs
  6. 2
      src/csharp/Grpc.IntegrationTesting/InteropClientServerTest.cs
  7. 2
      src/csharp/Grpc.IntegrationTesting/SslCredentialsTest.cs

@ -40,7 +40,7 @@ namespace Math
public static void Main(string[] args) public static void Main(string[] args)
{ {
var channel = new Channel("127.0.0.1", 23456, ChannelCredentials.Insecure); var channel = new Channel("127.0.0.1", 23456, ChannelCredentials.Insecure);
Math.MathClientBase client = new Math.MathClient(channel); Math.MathClient client = new Math.MathClient(channel);
MathExamples.DivExample(client); MathExamples.DivExample(client);
MathExamples.DivAsyncExample(client).Wait(); MathExamples.DivAsyncExample(client).Wait();

@ -38,19 +38,19 @@ namespace Math
{ {
public static class MathExamples public static class MathExamples
{ {
public static void DivExample(Math.MathClientBase client) public static void DivExample(Math.MathClient client)
{ {
DivReply result = client.Div(new DivArgs { Dividend = 10, Divisor = 3 }); DivReply result = client.Div(new DivArgs { Dividend = 10, Divisor = 3 });
Console.WriteLine("Div Result: " + result); Console.WriteLine("Div Result: " + result);
} }
public static async Task DivAsyncExample(Math.MathClientBase client) public static async Task DivAsyncExample(Math.MathClient client)
{ {
DivReply result = await client.DivAsync(new DivArgs { Dividend = 4, Divisor = 5 }); DivReply result = await client.DivAsync(new DivArgs { Dividend = 4, Divisor = 5 });
Console.WriteLine("DivAsync Result: " + result); Console.WriteLine("DivAsync Result: " + result);
} }
public static async Task FibExample(Math.MathClientBase client) public static async Task FibExample(Math.MathClient client)
{ {
using (var call = client.Fib(new FibArgs { Limit = 5 })) using (var call = client.Fib(new FibArgs { Limit = 5 }))
{ {
@ -59,7 +59,7 @@ namespace Math
} }
} }
public static async Task SumExample(Math.MathClientBase client) public static async Task SumExample(Math.MathClient client)
{ {
var numbers = new List<Num> var numbers = new List<Num>
{ {
@ -75,7 +75,7 @@ namespace Math
} }
} }
public static async Task DivManyExample(Math.MathClientBase client) public static async Task DivManyExample(Math.MathClient client)
{ {
var divArgsList = new List<DivArgs> var divArgsList = new List<DivArgs>
{ {
@ -90,7 +90,7 @@ namespace Math
} }
} }
public static async Task DependendRequestsExample(Math.MathClientBase client) public static async Task DependendRequestsExample(Math.MathClient client)
{ {
var numbers = new List<Num> var numbers = new List<Num>
{ {

@ -49,7 +49,7 @@ namespace Grpc.HealthCheck.Tests
const string Host = "localhost"; const string Host = "localhost";
Server server; Server server;
Channel channel; Channel channel;
Grpc.Health.V1.Health.HealthClientBase client; Grpc.Health.V1.Health.HealthClient client;
Grpc.HealthCheck.HealthServiceImpl serviceImpl; Grpc.HealthCheck.HealthServiceImpl serviceImpl;
[TestFixtureSetUp] [TestFixtureSetUp]

@ -112,7 +112,7 @@ namespace Grpc.IntegrationTesting
readonly PayloadConfig payloadConfig; readonly PayloadConfig payloadConfig;
readonly Histogram histogram; readonly Histogram histogram;
readonly BenchmarkService.BenchmarkServiceClientBase client; readonly BenchmarkService.BenchmarkServiceClient client;
readonly Task runnerTask; readonly Task runnerTask;
readonly CancellationTokenSource stoppedCts; readonly CancellationTokenSource stoppedCts;
readonly WallClockStopwatch wallClockStopwatch = new WallClockStopwatch(); readonly WallClockStopwatch wallClockStopwatch = new WallClockStopwatch();

@ -217,7 +217,7 @@ namespace Grpc.IntegrationTesting
} }
} }
public static void RunEmptyUnary(TestService.TestServiceClientBase client) public static void RunEmptyUnary(TestService.TestServiceClient client)
{ {
Console.WriteLine("running empty_unary"); Console.WriteLine("running empty_unary");
var response = client.EmptyCall(new Empty()); var response = client.EmptyCall(new Empty());
@ -225,7 +225,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static void RunLargeUnary(TestService.TestServiceClientBase client) public static void RunLargeUnary(TestService.TestServiceClient client)
{ {
Console.WriteLine("running large_unary"); Console.WriteLine("running large_unary");
var request = new SimpleRequest var request = new SimpleRequest
@ -241,7 +241,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunClientStreamingAsync(TestService.TestServiceClientBase client) public static async Task RunClientStreamingAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running client_streaming"); Console.WriteLine("running client_streaming");
@ -257,7 +257,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunServerStreamingAsync(TestService.TestServiceClientBase client) public static async Task RunServerStreamingAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running server_streaming"); Console.WriteLine("running server_streaming");
@ -281,7 +281,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunPingPongAsync(TestService.TestServiceClientBase client) public static async Task RunPingPongAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running ping_pong"); Console.WriteLine("running ping_pong");
@ -338,7 +338,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunEmptyStreamAsync(TestService.TestServiceClientBase client) public static async Task RunEmptyStreamAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running empty_stream"); Console.WriteLine("running empty_stream");
using (var call = client.FullDuplexCall()) using (var call = client.FullDuplexCall())
@ -434,7 +434,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunCancelAfterBeginAsync(TestService.TestServiceClientBase client) public static async Task RunCancelAfterBeginAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running cancel_after_begin"); Console.WriteLine("running cancel_after_begin");
@ -451,7 +451,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunCancelAfterFirstResponseAsync(TestService.TestServiceClientBase client) public static async Task RunCancelAfterFirstResponseAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running cancel_after_first_response"); Console.WriteLine("running cancel_after_first_response");
@ -477,7 +477,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunTimeoutOnSleepingServerAsync(TestService.TestServiceClientBase client) public static async Task RunTimeoutOnSleepingServerAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running timeout_on_sleeping_server"); Console.WriteLine("running timeout_on_sleeping_server");
@ -499,7 +499,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunCustomMetadataAsync(TestService.TestServiceClientBase client) public static async Task RunCustomMetadataAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running custom_metadata"); Console.WriteLine("running custom_metadata");
{ {
@ -546,7 +546,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static async Task RunStatusCodeAndMessageAsync(TestService.TestServiceClientBase client) public static async Task RunStatusCodeAndMessageAsync(TestService.TestServiceClient client)
{ {
Console.WriteLine("running status_code_and_message"); Console.WriteLine("running status_code_and_message");
var echoStatus = new EchoStatus var echoStatus = new EchoStatus
@ -580,7 +580,7 @@ namespace Grpc.IntegrationTesting
Console.WriteLine("Passed!"); Console.WriteLine("Passed!");
} }
public static void RunUnimplementedMethod(UnimplementedService.UnimplementedServiceClientBase client) public static void RunUnimplementedMethod(UnimplementedService.UnimplementedServiceClient client)
{ {
Console.WriteLine("running unimplemented_method"); Console.WriteLine("running unimplemented_method");
var e = Assert.Throws<RpcException>(() => client.UnimplementedCall(new Empty())); var e = Assert.Throws<RpcException>(() => client.UnimplementedCall(new Empty()));

@ -51,7 +51,7 @@ namespace Grpc.IntegrationTesting
const string Host = "localhost"; const string Host = "localhost";
Server server; Server server;
Channel channel; Channel channel;
TestService.TestServiceClientBase client; TestService.TestServiceClient client;
[TestFixtureSetUp] [TestFixtureSetUp]
public void Init() public void Init()

@ -53,7 +53,7 @@ namespace Grpc.IntegrationTesting
const string Host = "localhost"; const string Host = "localhost";
Server server; Server server;
Channel channel; Channel channel;
TestService.TestServiceClientBase client; TestService.TestServiceClient client;
[TestFixtureSetUp] [TestFixtureSetUp]
public void Init() public void Init()

Loading…
Cancel
Save