HomeSort by relevance Sort by last modified time
    Searched defs:RetriableStream (Results 1 - 4 of 4) sorted by null

  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
RetriableStreamTest.java 23 import static io.grpc.internal.RetriableStream.GRPC_PREVIOUS_RPC_ATTEMPTS;
55 import io.grpc.internal.RetriableStream.ChannelBufferMeter;
56 import io.grpc.internal.RetriableStream.Throttle;
74 /** Unit tests for {@link RetriableStream}. */
78 "Stream thrown away because RetriableStream committed";
94 RetriableStream.setRandom(
128 private final class RecordedRetriableStream extends RetriableStream<String> {
174 private final RetriableStream<String> retriableStream =
179 private RetriableStream<String> newThrottledRetriableStream(Throttle throttle)
    [all...]
ManagedChannelImplTest.java     [all...]
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
RetriableStream.java 50 abstract class RetriableStream<ReqT> implements ClientStream {
60 Status.CANCELLED.withDescription("Stream thrown away because RetriableStream committed");
97 RetriableStream(
330 throw new IllegalStateException("RetriableStream.writeMessage() should not be called directly");
516 RetriableStream.random = random;
745 // GuardedBy RetriableStream.lock
752 // GuardedBy RetriableStream.lock
783 // GuardedBy RetriableStream.lock
797 // GuardedBy RetriableStream.lock
824 // GuardedBy RetriableStream.loc
    [all...]
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 

Completed in 196 milliseconds