Home
last modified time | relevance | path

Searched refs:unaryCall (Results 1 – 19 of 19) sorted by relevance

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DCascadingTest.java109 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()
DCompressionTest.java200 stub.unaryCall(REQUEST); in compression()
250 public void unaryCall(SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) { in unaryCall() method in CompressionTest.LocalServer
DTransportCompressionTest.java121 assertEquals(goldenResponse, blockingStub.unaryCall(request));
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DHttp2Client.java219 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()
DAbstractInteropTest.java402 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 …]
DTestServiceImpl.java87 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/
DStubConfigTest.java88 stub.unaryCall(request, responseObserver); in testStubCallOptionsPopulatedToNewCall()
93 stub.unaryCall(request, responseObserver); in testStubCallOptionsPopulatedToNewCall()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/
DTransportBenchmark.java155 stub.unaryCall(SimpleRequest.getDefaultInstance()); in setUp()
188 return stub.unaryCall(simpleRequest); in unaryCall1024()
/external/grpc-grpc/src/objective-c/examples/SwiftSample/
DViewController.swift39 service.unaryCall(with: request) { response, error in in viewDidLoad()
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java223 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/
DLongLivedChannel.java66 SimpleResponse simpleResponse = blockingStub.unaryCall(request); in doGet()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncClient.java157 stub.unaryCall(request, new StreamObserver<SimpleResponse>() { in doUnaryCalls()
181 stub.unaryCall(request, this); in doUnaryCalls()
DOpenLoopClient.java180 stub.unaryCall(request, new StreamObserver<SimpleResponse>() { in newRpc()
DAsyncServer.java213 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/
DTestServiceGrpc.java336 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/
DTestService.java.txt261 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/
DTestService.java.txt255 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/
DLoadClient.java315 stub.unaryCall(simpleRequest); in run()
341 stub.unaryCall(simpleRequest, new StreamObserver<Messages.SimpleResponse>() { in run()
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt296 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,