Home
last modified time | relevance | path

Searched refs:withWaitForReady (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DAbstractStubTest.java62 public void withWaitForReady() { in withWaitForReady() method in AbstractStubTest
67 stub = stub.withWaitForReady(); in withWaitForReady()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DAbstractStub.java202 public final S withWaitForReady() { in withWaitForReady() method in AbstractStub
203 return build(channel, callOptions.withWaitForReady()); in withWaitForReady()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DCallOptionsTest.java57 .withWaitForReady()
77 assertThat(CallOptions.DEFAULT.withWaitForReady().isWaitForReady()).isTrue(); in withAndWithoutWaitForReady()
78 assertThat(CallOptions.DEFAULT.withWaitForReady().withoutWaitForReady().isWaitForReady()) in withAndWithoutWaitForReady()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServiceConfigInterceptorTest.java91 public void withWaitForReady() { in withWaitForReady() method in ServiceConfigInterceptorTest
212 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withWaitForReady(), channel); in withoutWaitForReady()
DDelayedClientTransportTest.java290 .withWaitForReady(); in reprocessSemantics()
DManagedChannelImplTest.java923 callOptions = callOptions.withWaitForReady(); in subtestFailRpcFromBalancer()
985 channel.newCall(method, CallOptions.DEFAULT.withWaitForReady()); in allServersFailedToConnect()
1202 oob1.newCall(method, CallOptions.DEFAULT.withWaitForReady()); in oobchannels()
1788 channel.newCall(method, CallOptions.DEFAULT.withWaitForReady()); in panic_bufferedCallsWillFail()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DCallOptions.java148 public CallOptions withWaitForReady() { in withWaitForReady() method in CallOptions
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServiceConfigInterceptor.java375 info.waitForReady ? callOptions.withWaitForReady() : callOptions.withoutWaitForReady(); in interceptCall()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java486 lbRequestWriter = stub.withWaitForReady().balanceLoad(this); in start()