Home
last modified time | relevance | path

Searched defs:retriableStream (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java174 private final RetriableStream<String> retriableStream = field in RetriableStreamTest
1227 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithoutPushback() local
1247 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback() local
1269 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback() local
1292 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithRetriablePushback() local
1321 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithNonRetriablePushback() local
1343 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithNonRetriablePushback() local
1365 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttleStream_Succeed() local
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java969 Status add(RetriableStream<?> retriableStream) { in add()
979 void remove(RetriableStream<?> retriableStream) { in remove()
DClientCallImpl.java419 RetriableStream<ReqT> retriableStream = ((RetriableStream<ReqT>) stream); in sendMessage() local