OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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