| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | Http2OkHttpTest.java | 134 assertEquals(EMPTY, blockingStub.emptyCall(EMPTY)); in receivedDataForFinishedStream()
143 TestServiceGrpc.TestServiceBlockingStub blockingStub = in wrongHostNameFailHostnameVerification() local
148 blockingStub.emptyCall(Empty.getDefaultInstance()); in wrongHostNameFailHostnameVerification()
171 TestServiceGrpc.TestServiceBlockingStub blockingStub = in hostnameVerifierWithBadHostname() local
174 blockingStub.emptyCall(Empty.getDefaultInstance()); in hostnameVerifierWithBadHostname()
191 TestServiceGrpc.TestServiceBlockingStub blockingStub = in hostnameVerifierWithCorrectHostname() local
196 blockingStub.emptyCall(Empty.getDefaultInstance()); in hostnameVerifierWithCorrectHostname()
|
| D | CascadingTest.java | 73 private TestServiceGrpc.TestServiceBlockingStub blockingStub; field in CascadingTest
84 blockingStub = TestServiceGrpc.newBlockingStub(channel); in setUp()
166 blockingStub.unaryCall(Messages.SimpleRequest.newBuilder().setResponseSize(3).build()); in testCascadingCancellationViaLeafFailure()
200 responseObserver.onNext(blockingStub.unaryCall(request)); in testDeadlinePropagation()
216 blockingStub.withDeadline(initialDeadline).unaryCall(SimpleRequest.getDefaultInstance()); in testDeadlinePropagation()
251 blockingStub.unaryCall(request); in startChainingServer()
|
| D | TransportCompressionTest.java | 121 assertEquals(goldenResponse, blockingStub.unaryCall(request));
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | Http2Client.java | 89 protected TestServiceGrpc.TestServiceBlockingStub blockingStub; field in Http2Client
141 blockingStub = TestServiceGrpc.newBlockingStub(channel); in setUp()
219 blockingStub.unaryCall(simpleRequest); in rstAfterHeader()
259 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse); in goAway()
261 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse); in goAway()
265 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse); in ping()
272 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse); in maxStreams()
330 TestServiceGrpc.TestServiceBlockingStub blockingStub = in run() local
332 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse); in run()
|
| D | AbstractInteropTest.java | 255 protected TestServiceGrpc.TestServiceBlockingStub blockingStub; field in AbstractInteropTest
287 blockingStub = in setUp()
293 blockingStub = blockingStub.withInterceptors(additionalInterceptors); in setUp()
346 assertEquals(EMPTY, blockingStub.emptyCall(EMPTY)); in emptyUnary()
402 assertEquals(goldenResponse, blockingStub.unaryCall(request)); in largeUnary()
435 blockingStub.unaryCall(expectCompressedRequest); in clientCompressedUnary()
444 goldenResponse, blockingStub.withCompression("gzip").unaryCall(expectCompressedRequest)); in clientCompressedUnary()
451 assertEquals(goldenResponse, blockingStub.unaryCall(expectUncompressedRequest)); in clientCompressedUnary()
485 assertEquals(goldenResponse, blockingStub.unaryCall(responseShouldBeCompressed)); in serverCompressedUnary()
492 assertEquals(goldenResponse, blockingStub.unaryCall(responseShouldBeUncompressed)); in serverCompressedUnary()
[all …]
|
| /external/grpc-grpc-java/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/ |
| D | RouteGuideActivity.java | 181 String run(RouteGuideBlockingStub blockingStub, RouteGuideStub asyncStub) throws Exception; in run() argument
186 public String run(RouteGuideBlockingStub blockingStub, RouteGuideStub asyncStub) in run() argument
188 return getFeature(409146138, -746188906, blockingStub); in run()
192 private String getFeature(int lat, int lon, RouteGuideBlockingStub blockingStub) in getFeature() argument
200 feature = blockingStub.getFeature(request); in getFeature()
221 public String run(RouteGuideBlockingStub blockingStub, RouteGuideStub asyncStub) in run() argument
223 return listFeatures(400000000, -750000000, 420000000, -730000000, blockingStub); in run()
231 int lowLat, int lowLon, int hiLat, int hiLon, RouteGuideBlockingStub blockingStub) in listFeatures() argument
248 features = blockingStub.listFeatures(request); in listFeatures()
262 public String run(RouteGuideBlockingStub blockingStub, RouteGuideStub asyncStub) in run() argument
[all …]
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworld/ |
| D | HelloWorldClient.java | 33 private final GreeterGrpc.GreeterBlockingStub blockingStub; field in HelloWorldClient
47 blockingStub = GreeterGrpc.newBlockingStub(channel); in HelloWorldClient()
60 response = blockingStub.sayHello(request); in greet()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/experimental/ |
| D | CompressingHelloWorldClient.java | 41 private final GreeterGrpc.GreeterBlockingStub blockingStub; field in CompressingHelloWorldClient
48 blockingStub = GreeterGrpc.newBlockingStub(channel); in CompressingHelloWorldClient()
63 response = blockingStub.withCompression("gzip").sayHello(request); in greet()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
| D | CustomHeaderClient.java | 40 private final GreeterGrpc.GreeterBlockingStub blockingStub; field in CustomHeaderClient
51 blockingStub = GreeterGrpc.newBlockingStub(channel); in CustomHeaderClient()
66 response = blockingStub.sayHello(request); in greet()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/ |
| D | HelloJsonClient.java | 49 private final HelloJsonStub blockingStub; field in HelloJsonClient
56 blockingStub = new HelloJsonStub(channel); in HelloJsonClient()
69 response = blockingStub.sayHello(request); in greet()
|
| /external/flatbuffers/grpc/tests/ |
| D | JavaGrpcTest.java | 49 static MonsterStorageGrpc.MonsterStorageBlockingStub blockingStub; field in JavaGrpcTest
147 blockingStub = MonsterStorageGrpc.newBlockingStub(channel);
154 Stat stat = blockingStub.store(monsterRequest);
162 Stat stat = blockingStub.store(monsterRequest);
163 Iterator<Monster> iterator = blockingStub.retrieve(stat);
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworldtls/ |
| D | HelloWorldClientTls.java | 44 private final GreeterGrpc.GreeterBlockingStub blockingStub; field in HelloWorldClientTls
77 blockingStub = GreeterGrpc.newBlockingStub(channel); in HelloWorldClientTls()
92 response = blockingStub.sayHello(request); in greet()
|
| /external/grpc-grpc-java/examples/example-kotlin/src/test/kotlin/io/grpc/examples/helloworld/ |
| D | HelloWorldServerTest.kt | 62 val blockingStub = GreeterGrpc.newBlockingStub( in greeterImpl_replyMessage() constant
68 val reply = blockingStub.sayHello(HelloRequest.newBuilder().setName("test name").build()) in greeterImpl_replyMessage()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/helloworld/ |
| D | HelloWorldServerTest.java | 60 GreeterGrpc.GreeterBlockingStub blockingStub = GreeterGrpc.newBlockingStub( in greeterImpl_replyMessage() local
66 blockingStub.sayHello(HelloRequest.newBuilder().setName( "test name").build()); in greeterImpl_replyMessage()
|
| /external/grpc-grpc-java/examples/example-kotlin/src/main/kotlin/io/grpc/examples/helloworld/ |
| D | HelloWorldClient.kt | 32 private val blockingStub: GreeterGrpc.GreeterBlockingStub constant in io.grpc.examples.helloworld.HelloWorldClient
54 blockingStub.sayHello(request) in greet()
|
| /external/opencensus-java/examples/src/main/java/io/opencensus/examples/grpc/helloworld/ |
| D | HelloWorldClient.java | 52 private final GreeterGrpc.GreeterBlockingStub blockingStub; field in HelloWorldClient
67 blockingStub = GreeterGrpc.newBlockingStub(channel); in HelloWorldClient()
84 response = blockingStub.sayHello(request); in greet()
|
| /external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/ |
| D | LongLivedChannel.java | 64 TestServiceGrpc.TestServiceBlockingStub blockingStub = in doGet() local
66 SimpleResponse simpleResponse = blockingStub.unaryCall(request); in doGet()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideClient.java | 44 private final RouteGuideBlockingStub blockingStub; field in RouteGuideClient
58 blockingStub = RouteGuideGrpc.newBlockingStub(channel); in RouteGuideClient()
76 feature = blockingStub.getFeature(request); in getFeature()
113 features = blockingStub.listFeatures(request); in listFeatures()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/ |
| D | HeaderClientInterceptorTest.java | 86 GreeterBlockingStub blockingStub = GreeterGrpc.newBlockingStub( in clientHeaderDeliveredToServer() local
91 blockingStub.sayHello(HelloRequest.getDefaultInstance()); in clientHeaderDeliveredToServer()
|
| D | HeaderServerInterceptorTest.java | 109 GreeterBlockingStub blockingStub = GreeterGrpc.newBlockingStub(channel) in serverHeaderDeliveredToClient()
113 blockingStub.sayHello(HelloRequest.getDefaultInstance()); in serverHeaderDeliveredToClient()
|