HomeSort by relevance Sort by last modified time
    Searched defs:retriableStream (Results 1 - 3 of 3) 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...]
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
ClientCallImpl.java 131 <ReqT> RetriableStream<ReqT> newRetriableStream(
417 if (stream instanceof RetriableStream) {
419 RetriableStream<ReqT> retriableStream = ((RetriableStream<ReqT>) stream);
420 retriableStream.sendMessage(message);
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 

Completed in 912 milliseconds