Searched refs:SimpleServiceGrpc (Results 1 – 5 of 5) sorted by relevance
53 assertEquals("grpc.testing.SimpleService", SimpleServiceGrpc.getServiceDescriptor().getName()); in serviceDescriptor()60 genericTypeShouldMatchWhenAssigned = SimpleServiceGrpc.getUnaryRpcMethod(); in serviceMethodDescriotrs()63 genericTypeShouldMatchWhenAssigned = SimpleServiceGrpc.getClientStreamingRpcMethod(); in serviceMethodDescriotrs()66 genericTypeShouldMatchWhenAssigned = SimpleServiceGrpc.getServerStreamingRpcMethod(); in serviceMethodDescriotrs()69 genericTypeShouldMatchWhenAssigned = SimpleServiceGrpc.getBidiStreamingRpcMethod(); in serviceMethodDescriotrs()75 assertTrue(SimpleServiceGrpc.getUnaryRpcMethod().isSampledToLocalTracing()); in generatedMethodsAreSampledToLocalTracing()110 if (!rootElement.asType().toString().equals(SimpleServiceGrpc.class.getCanonicalName())) { in process()123 SimpleServiceGrpc.getUnaryRpcMethod(), methodToAnnotation.get("getUnaryRpcMethod")); in process()125 SimpleServiceGrpc.getServerStreamingRpcMethod(), in process()128 SimpleServiceGrpc.getClientStreamingRpcMethod(), in process()[all …]
26 import io.grpc.testing.protobuf.SimpleServiceGrpc;60 SimpleServiceGrpc.SimpleServiceBlockingStub stub = in serverAllowsServicesToBeAddedViaServiceRegistry_withoutDirectExecutor()61 SimpleServiceGrpc.newBlockingStub(grpcServerRule1.getChannel()); in serverAllowsServicesToBeAddedViaServiceRegistry_withoutDirectExecutor()79 SimpleServiceGrpc.SimpleServiceBlockingStub stub = in serviceIsNotRunOnSameThreadAsTest_withoutDirectExecutor()80 SimpleServiceGrpc.newBlockingStub(grpcServerRule1.getChannel()); in serviceIsNotRunOnSameThreadAsTest_withoutDirectExecutor()110 SimpleServiceGrpc.SimpleServiceBlockingStub stub = in serverAllowsServicesToBeAddedViaServiceRegistry_withDirectExecutor()111 SimpleServiceGrpc.newBlockingStub(grpcServerRule2.getChannel()); in serverAllowsServicesToBeAddedViaServiceRegistry_withDirectExecutor()129 SimpleServiceGrpc.SimpleServiceBlockingStub stub = in serviceIsRunOnSameThreadAsTest_withDirectExecutor()130 SimpleServiceGrpc.newBlockingStub(grpcServerRule2.getChannel()); in serviceIsRunOnSameThreadAsTest_withDirectExecutor()182 private static class TestServiceImpl extends SimpleServiceGrpc.SimpleServiceImplBase {
26 public final class SimpleServiceGrpc { class28 private SimpleServiceGrpc() {} in SimpleServiceGrpc() method in SimpleServiceGrpc44 if ((getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod) == null) { in getUnaryRpcMethod()45 synchronized (SimpleServiceGrpc.class) { in getUnaryRpcMethod()46 if ((getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod) == null) { in getUnaryRpcMethod()47 SimpleServiceGrpc.getUnaryRpcMethod = getUnaryRpcMethod = in getUnaryRpcMethod()76 if ((getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod) == null) { in getClientStreamingRpcMethod()77 synchronized (SimpleServiceGrpc.class) { in getClientStreamingRpcMethod()78 if ((getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod) == null) { in getClientStreamingRpcMethod()79 SimpleServiceGrpc.getClientStreamingRpcMethod = getClientStreamingRpcMethod = in getClientStreamingRpcMethod()[all …]
33 import io.grpc.testing.protobuf.SimpleServiceGrpc;179 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in basicClientServerIntegrationTest()215 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in serverRejectsUntrustedClientCert()256 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in noClientAuthFailure()300 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in clientRejectsUntrustedServerCert()343 private static class SimpleServiceImpl extends SimpleServiceGrpc.SimpleServiceImplBase {
34 import io.grpc.testing.protobuf.SimpleServiceGrpc;35 import io.grpc.testing.protobuf.SimpleServiceGrpc.SimpleServiceBlockingStub;36 import io.grpc.testing.protobuf.SimpleServiceGrpc.SimpleServiceImplBase;83 SimpleServiceBlockingStub stub = SimpleServiceGrpc.newBlockingStub(channel); in basic()101 SimpleServiceBlockingStub stub = SimpleServiceGrpc.newBlockingStub(channel); in tcnative()