Searched defs:retriableStream (Results 1 – 2 of 2) sorted by relevance
191 private RetriableStream<String> retriableStream = field in RetriableStreamTest1592 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithoutPushback() local1613 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback() local1636 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback() local1660 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithRetriablePushback() local1690 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithNonRetriablePushback() local1713 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithNonRetriablePushback() local1736 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttleStream_Succeed() local
524 RetriableStream<ReqT> retriableStream = (RetriableStream<ReqT>) stream; in sendMessageInternal() local