HomeSort by relevance Sort by last modified time
    Searched refs:unaryCall (Results 1 - 16 of 16) sorted by null

  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
CascadingTest.java 109 future = futureStub.unaryCall(SimpleRequest.getDefaultInstance());
141 Future<SimpleResponse> future = futureStub.unaryCall(SimpleRequest.getDefaultInstance());
166 blockingStub.unaryCall(Messages.SimpleRequest.newBuilder().setResponseSize(3).build());
190 public void unaryCall(final SimpleRequest request,
200 responseObserver.onNext(blockingStub.unaryCall(request));
216 blockingStub.withDeadline(initialDeadline).unaryCall(SimpleRequest.getDefaultInstance());
233 public void unaryCall(final SimpleRequest request,
251 blockingStub.unaryCall(request);
305 asyncStub.unaryCall(req,
CompressionTest.java 200 stub.unaryCall(REQUEST);
250 public void unaryCall(SimpleRequest request, StreamObserver<SimpleResponse> responseObserver) {
TransportCompressionTest.java 121 assertEquals(goldenResponse, blockingStub.unaryCall(request));
  /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
Http2Client.java 219 blockingStub.unaryCall(simpleRequest);
229 asyncStub.unaryCall(simpleRequest, responseObserver);
245 asyncStub.unaryCall(simpleRequest, responseObserver);
259 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse);
261 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse);
265 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse);
272 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse);
332 assertResponseEquals(blockingStub.unaryCall(simpleRequest), goldenResponse);
AbstractInteropTest.java 402 assertEquals(goldenResponse, blockingStub.unaryCall(request));
404 assertStatsTrace("grpc.testing.TestService/UnaryCall", Status.Code.OK,
435 blockingStub.unaryCall(expectCompressedRequest);
440 assertStatsTrace("grpc.testing.TestService/UnaryCall", Status.Code.INVALID_ARGUMENT);
444 goldenResponse, blockingStub.withCompression("gzip").unaryCall(expectCompressedRequest));
446 "grpc.testing.TestService/UnaryCall",
451 assertEquals(goldenResponse, blockingStub.unaryCall(expectUncompressedRequest));
453 "grpc.testing.TestService/UnaryCall",
485 assertEquals(goldenResponse, blockingStub.unaryCall(responseShouldBeCompressed));
487 "grpc.testing.TestService/UnaryCall",
    [all...]
TestServiceImpl.java 87 public void unaryCall(SimpleRequest req, StreamObserver<SimpleResponse> responseObserver) {
  /external/grpc-grpc/src/objective-c/examples/SwiftSample/
ViewController.swift 39 service.unaryCall(with: request) { response, error in
69 let method = GRPCProtoMethod(package: "grpc.testing", service: "TestService", method: "UnaryCall")!
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/
StubConfigTest.java 88 stub.unaryCall(request, responseObserver);
93 stub.unaryCall(request, responseObserver);
  /external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/
LongLivedChannel.java 66 SimpleResponse simpleResponse = blockingStub.unaryCall(request);
  /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/
TransportBenchmark.java 155 stub.unaryCall(SimpleRequest.getDefaultInstance());
188 return stub.unaryCall(simpleRequest);
  /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
BenchmarkServiceGrpc.java 34 fullMethodName = SERVICE_NAME + '/' + "UnaryCall",
48 "grpc.testing.BenchmarkService", "UnaryCall"))
54 .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("UnaryCall"))
223 public void unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request,
338 public void unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request,
418 public io.grpc.benchmarks.proto.Messages.SimpleResponse unaryCall(io.grpc.benchmarks.proto.Messages.SimpleRequest request) {
460 public com.google.common.util.concurrent.ListenableFuture<io.grpc.benchmarks.proto.Messages.SimpleResponse> unaryCall(
491 serviceImpl.unaryCall((io.grpc.benchmarks.proto.Messages.SimpleRequest) request,
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncClient.java 157 stub.unaryCall(request, new StreamObserver<SimpleResponse>() {
167 System.err.println("Encountered an error in unaryCall. Status is " + status);
181 stub.unaryCall(request, this);
OpenLoopClient.java 180 stub.unaryCall(request, new StreamObserver<SimpleResponse>() {
191 System.err.println("Encountered an error in unaryCall. Status is " + status);
AsyncServer.java 213 public void unaryCall(Messages.SimpleRequest request,
  /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
TestServiceGrpc.java 70 fullMethodName = SERVICE_NAME + '/' + "UnaryCall",
84 "grpc.testing.TestService", "UnaryCall"))
90 .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall"))
336 public void unaryCall(io.grpc.testing.integration.Messages.SimpleRequest request,
511 public void unaryCall(io.grpc.testing.integration.Messages.SimpleRequest request,
631 public io.grpc.testing.integration.Messages.SimpleResponse unaryCall(io.grpc.testing.integration.Messages.SimpleRequest request) {
    [all...]
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
LoadClient.java 315 stub.unaryCall(simpleRequest);
341 stub.unaryCall(simpleRequest, new StreamObserver<Messages.SimpleResponse>() {

Completed in 287 milliseconds