OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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