/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
D | CascadingTest.java | 109 future = futureStub.unaryCall(SimpleRequest.getDefaultInstance()); in testCascadingCancellationViaOuterContextCancellation() 141 Future<SimpleResponse> future = futureStub.unaryCall(SimpleRequest.getDefaultInstance()); in testCascadingCancellationViaRpcCancel() 166 blockingStub.unaryCall(Messages.SimpleRequest.newBuilder().setResponseSize(3).build()); in testCascadingCancellationViaLeafFailure() 190 public void unaryCall(final SimpleRequest request, in testDeadlinePropagation() method in CascadingTest.DeadlineSaver 200 responseObserver.onNext(blockingStub.unaryCall(request)); in testDeadlinePropagation() 216 blockingStub.withDeadline(initialDeadline).unaryCall(SimpleRequest.getDefaultInstance()); in testDeadlinePropagation() 233 public void unaryCall(final SimpleRequest request, in startChainingServer() method in CascadingTest.ChainingService 251 blockingStub.unaryCall(request); in startChainingServer() 305 asyncStub.unaryCall(req, in startCallTreeServer()
|
D | CompressionTest.java | 200 stub.unaryCall(REQUEST); in compression() 250 public void unaryCall(SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) { in unaryCall() method in CompressionTest.LocalServer
|
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 | 219 blockingStub.unaryCall(simpleRequest); in rstAfterHeader() 229 asyncStub.unaryCall(simpleRequest, responseObserver); in rstAfterData() 245 asyncStub.unaryCall(simpleRequest, responseObserver); in rstDuringData() 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() 332 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse); in run()
|
D | AbstractInteropTest.java | 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() 959 assertEquals(goldenResponse, blockingStub.unaryCall(request)); in veryLargeRequest() 975 assertEquals(goldenResponse, blockingStub.unaryCall(request)); in veryLargeResponse() 1426 SimpleResponse response = blockingStub.unaryCall(request); in customMetadata() 1478 blockingStub.unaryCall(SimpleRequest.getDefaultInstance()); in censusContextsPropagated() [all …]
|
D | TestServiceImpl.java | 87 public void unaryCall(SimpleRequest req, StreamObserver<SimpleResponse> responseObserver) { in unaryCall() method in TestServiceImpl
|
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/ |
D | StubConfigTest.java | 88 stub.unaryCall(request, responseObserver); in testStubCallOptionsPopulatedToNewCall() 93 stub.unaryCall(request, responseObserver); in testStubCallOptionsPopulatedToNewCall()
|
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/ |
D | TransportBenchmark.java | 155 stub.unaryCall(SimpleRequest.getDefaultInstance()); in setUp() 188 return stub.unaryCall(simpleRequest); in unaryCall1024()
|
/external/grpc-grpc/src/objective-c/examples/SwiftSample/ |
D | ViewController.swift | 39 service.unaryCall(with: request) { response, error in in viewDidLoad()
|
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
D | BenchmarkServiceGrpc.java | 223 public void unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request, in unaryCall() method in BenchmarkServiceGrpc.BenchmarkServiceImplBase 338 public void unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request, in unaryCall() method in BenchmarkServiceGrpc.BenchmarkServiceStub 418 …public io.grpc.benchmarks.proto.Messages.SimpleResponse unaryCall(io.grpc.benchmarks.proto.Message… in unaryCall() method in BenchmarkServiceGrpc.BenchmarkServiceBlockingStub 460 …ommon.util.concurrent.ListenableFuture<io.grpc.benchmarks.proto.Messages.SimpleResponse> unaryCall( in unaryCall() method in BenchmarkServiceGrpc.BenchmarkServiceFutureStub 491 serviceImpl.unaryCall((io.grpc.benchmarks.proto.Messages.SimpleRequest) request, in invoke()
|
/external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/ |
D | LongLivedChannel.java | 66 SimpleResponse simpleResponse = blockingStub.unaryCall(request); in doGet()
|
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
D | AsyncClient.java | 157 stub.unaryCall(request, new StreamObserver<SimpleResponse>() { in doUnaryCalls() 181 stub.unaryCall(request, this); in doUnaryCalls()
|
D | OpenLoopClient.java | 180 stub.unaryCall(request, new StreamObserver<SimpleResponse>() { in newRpc()
|
D | AsyncServer.java | 213 public void unaryCall(Messages.SimpleRequest request, in unaryCall() method in AsyncServer.BenchmarkServiceImpl
|
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
D | TestServiceGrpc.java | 336 public void unaryCall(io.grpc.testing.integration.Messages.SimpleRequest request, in unaryCall() method in TestServiceGrpc.TestServiceImplBase 511 public void unaryCall(io.grpc.testing.integration.Messages.SimpleRequest request, in unaryCall() method in TestServiceGrpc.TestServiceStub 631 …public io.grpc.testing.integration.Messages.SimpleResponse unaryCall(io.grpc.testing.integration.M… in unaryCall() method in TestServiceGrpc.TestServiceBlockingStub 710 …on.util.concurrent.ListenableFuture<io.grpc.testing.integration.Messages.SimpleResponse> unaryCall( in unaryCall() method in TestServiceGrpc.TestServiceFutureStub 773 serviceImpl.unaryCall((io.grpc.testing.integration.Messages.SimpleRequest) request, in invoke()
|
/external/grpc-grpc-java/compiler/src/test/golden/ |
D | TestService.java.txt | 261 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request, 399 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request, 496 …public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.Simple… 541 …le.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> unaryCall( 573 serviceImpl.unaryCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
|
/external/grpc-grpc-java/compiler/src/testLite/golden/ |
D | TestService.java.txt | 255 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request, 393 public void unaryCall(io.grpc.testing.compiler.Test.SimpleRequest request, 490 …public io.grpc.testing.compiler.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.Test.Simple… 535 …le.common.util.concurrent.ListenableFuture<io.grpc.testing.compiler.Test.SimpleResponse> unaryCall( 567 serviceImpl.unaryCall((io.grpc.testing.compiler.Test.SimpleRequest) request,
|
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
D | LoadClient.java | 315 stub.unaryCall(simpleRequest); in run() 341 stub.unaryCall(simpleRequest, new StreamObserver<Messages.SimpleResponse>() { in run()
|
/external/grpc-grpc-java/compiler/src/testNano/golden/ |
D | TestService.java.txt | 296 public void unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request, 434 public void unaryCall(io.grpc.testing.compiler.nano.Test.SimpleRequest request, 531 …public io.grpc.testing.compiler.nano.Test.SimpleResponse unaryCall(io.grpc.testing.compiler.nano.T… 576 …mmon.util.concurrent.ListenableFuture<io.grpc.testing.compiler.nano.Test.SimpleResponse> unaryCall( 608 serviceImpl.unaryCall((io.grpc.testing.compiler.nano.Test.SimpleRequest) request,
|