Home
last modified time | relevance | path

Searched refs:newBlockingStub (Results 1 – 25 of 61) sorted by relevance

123

/external/grpc-grpc-java/testing/src/test/java/io/grpc/testing/
DGrpcServerRuleTest.java61 SimpleServiceGrpc.newBlockingStub(grpcServerRule1.getChannel()); in serverAllowsServicesToBeAddedViaServiceRegistry_withoutDirectExecutor()
80 SimpleServiceGrpc.newBlockingStub(grpcServerRule1.getChannel()); in serviceIsNotRunOnSameThreadAsTest_withoutDirectExecutor()
111 SimpleServiceGrpc.newBlockingStub(grpcServerRule2.getChannel()); in serverAllowsServicesToBeAddedViaServiceRegistry_withDirectExecutor()
130 SimpleServiceGrpc.newBlockingStub(grpcServerRule2.getChannel()); in serviceIsRunOnSameThreadAsTest_withDirectExecutor()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DReconnectTestClient.java71 controlStub = ReconnectServiceGrpc.newBlockingStub(controlChannel); in runTest()
81 retryStub = ReconnectServiceGrpc.newBlockingStub(retryChannel); in runTest()
DHttp2Client.java141 blockingStub = TestServiceGrpc.newBlockingStub(channel); in setUp()
331 TestServiceGrpc.newBlockingStub(channel); in run()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DTlsTest.java179 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in basicClientServerIntegrationTest()
215 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in serverRejectsUntrustedClientCert()
256 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in noClientAuthFailure()
300 SimpleServiceGrpc.SimpleServiceBlockingStub client = SimpleServiceGrpc.newBlockingStub(channel); in clientRejectsUntrustedServerCert()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DHttp2OkHttpTest.java144 TestServiceGrpc.newBlockingStub(channel); in wrongHostNameFailHostnameVerification()
172 TestServiceGrpc.newBlockingStub(channel); in hostnameVerifierWithBadHostname()
192 TestServiceGrpc.newBlockingStub(channel); in hostnameVerifierWithCorrectHostname()
DStressTestClientTest.java135 MetricsServiceGrpc.MetricsServiceBlockingStub stub = MetricsServiceGrpc.newBlockingStub(ch); in gaugesShouldBeExported()
/external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/
DShadingTest.java83 SimpleServiceBlockingStub stub = SimpleServiceGrpc.newBlockingStub(channel); in basic()
101 SimpleServiceBlockingStub stub = SimpleServiceGrpc.newBlockingStub(channel); in tcnative()
/external/grpc-grpc-java/examples/example-kotlin/src/test/kotlin/io/grpc/examples/helloworld/
DHelloWorldServerTest.kt62 val blockingStub = GreeterGrpc.newBlockingStub( in greeterImpl_replyMessage()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/helloworld/
DHelloWorldServerTest.java60 GreeterGrpc.GreeterBlockingStub blockingStub = GreeterGrpc.newBlockingStub( in greeterImpl_replyMessage()
/external/grpc-grpc-java/examples/example-kotlin/src/main/kotlin/io/grpc/examples/helloworld/
DHelloWorldClient.kt33 = GreeterGrpc.newBlockingStub(channel)
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworld/
DHelloWorldClient.java47 blockingStub = GreeterGrpc.newBlockingStub(channel); in HelloWorldClient()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/experimental/
DCompressingHelloWorldClient.java48 blockingStub = GreeterGrpc.newBlockingStub(channel); in CompressingHelloWorldClient()
/external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/
DLongLivedChannel.java65 TestServiceGrpc.newBlockingStub(channel); in doGet()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DCustomHeaderClient.java51 blockingStub = GreeterGrpc.newBlockingStub(channel); in CustomHeaderClient()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/alts/
DHelloWorldAltsClient.java86 GreeterGrpc.GreeterBlockingStub stub = GreeterGrpc.newBlockingStub(channel); in run()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderClientInterceptorTest.java86 GreeterBlockingStub blockingStub = GreeterGrpc.newBlockingStub( in clientHeaderDeliveredToServer()
DHeaderServerInterceptorTest.java109 GreeterBlockingStub blockingStub = GreeterGrpc.newBlockingStub(channel) in serverHeaderDeliveredToClient()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/
DStubConfigTest.java73 TestServiceGrpc.TestServiceBlockingStub stub = TestServiceGrpc.newBlockingStub(channel); in testConfigureDeadline()
/external/grpc-grpc-java/examples/example-kotlin/android/helloworld/app/src/main/kotlin/io/grpc/helloworldexample/
DHelloworldActivity.kt71 val stub = GreeterGrpc.newBlockingStub(channel) in doInBackground()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworldtls/
DHelloWorldClientTls.java77 blockingStub = GreeterGrpc.newBlockingStub(channel); in HelloWorldClientTls()
/external/grpc-grpc-java/examples/android/helloworld/app/src/main/java/io/grpc/helloworldexample/
DHelloworldActivity.java88 GreeterGrpc.GreeterBlockingStub stub = GreeterGrpc.newBlockingStub(channel); in doInBackground()
/external/opencensus-java/examples/src/main/java/io/opencensus/examples/grpc/helloworld/
DHelloWorldClient.java67 blockingStub = GreeterGrpc.newBlockingStub(channel); in HelloWorldClient()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/
DTransportBenchmark.java153 stub = BenchmarkServiceGrpc.newBlockingStub(channel); in setUp()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/
DErrorHandlingClient.java81 GreeterBlockingStub stub = GreeterGrpc.newBlockingStub(channel); in blockingCall()
/external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/
DClientCacheExampleActivity.java136 GreeterGrpc.GreeterBlockingStub stub = GreeterGrpc.newBlockingStub(channelToUse); in doInBackground()

123