Searched refs:newThrottledRetriableStream (Results 1 – 1 of 1) sorted by relevance
175 newThrottledRetriableStream(null /* throttle */);179 private RetriableStream<String> newThrottledRetriableStream(Throttle throttle) { in newThrottledRetriableStream() method in RetriableStreamTest1227 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithoutPushback()1247 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback()1269 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback()1292 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithRetriablePushback()1321 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithRetriableStatusCode_WithNonRetriablePushback()1343 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttledStream_FailWithNonRetriableStatusCode_WithNonRetriablePushback()1365 RetriableStream<String> retriableStream = newThrottledRetriableStream(throttle); in throttleStream_Succeed()