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