Home
last modified time | relevance | path

Searched refs:RetriableStream (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java23 import static io.grpc.internal.RetriableStream.GRPC_PREVIOUS_RPC_ATTEMPTS;
55 import io.grpc.internal.RetriableStream.ChannelBufferMeter;
56 import io.grpc.internal.RetriableStream.Throttle;
94 RetriableStream.setRandom( in RetriableStream.setRandom()
128 private final class RecordedRetriableStream extends RetriableStream<String> {
174 private final RetriableStream<String> retriableStream =
179 private RetriableStream<String> newThrottledRetriableStream(Throttle throttle) { in newThrottledRetriableStream()
1085 headers.put(RetriableStream.GRPC_RETRY_PUSHBACK_MS, "" + pushbackInMillis); in pushback()
1101 headers.put(RetriableStream.GRPC_RETRY_PUSHBACK_MS, "" + pushbackInMillis); in pushback()
1161 headers.put(RetriableStream.GRPC_RETRY_PUSHBACK_MS, "" + pushbackInMillis); in pushback()
[all …]
DRetryPolicyTest.java33 import io.grpc.internal.RetriableStream.Throttle;
DManagedChannelImplTest.java2625 RetriableStream.setRandom( in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DClientCallImpl.java131 <ReqT> RetriableStream<ReqT> newRetriableStream( in newRetriableStream()
417 if (stream instanceof RetriableStream) { in sendMessage()
419 RetriableStream<ReqT> retriableStream = ((RetriableStream<ReqT>) stream); in sendMessage()
DManagedChannelImpl.java63 import io.grpc.internal.RetriableStream.ChannelBufferMeter;
64 import io.grpc.internal.RetriableStream.Throttle;
504 public <ReqT> RetriableStream<ReqT> newRetriableStream(
510 return new RetriableStream<ReqT>(
980 Status add(RetriableStream<?> retriableStream) { in add()
990 void remove(RetriableStream<?> retriableStream) { in remove()
DRetriableStream.java50 abstract class RetriableStream<ReqT> implements ClientStream { class
97 RetriableStream( in RetriableStream() method in RetriableStream
516 RetriableStream.random = random; in setRandom()
DOobChannel.java97 public <ReqT> RetriableStream<ReqT> newRetriableStream(MethodDescriptor<ReqT, ?> method,
DServiceConfigUtil.java24 import io.grpc.internal.RetriableStream.Throttle;