Uses of Class
io.grpc.internal.RetriableStream.Substream
-
Packages that use RetriableStream.Substream Package Description io.grpc.internal Interfaces and implementations that are internal to gRPC. -
-
Uses of RetriableStream.Substream in io.grpc.internal
Fields in io.grpc.internal declared as RetriableStream.Substream Modifier and Type Field Description private RetriableStream.Substream
RetriableStream.BufferSizeTracer. substream
(package private) RetriableStream.Substream
RetriableStream.Sublistener. substream
(package private) RetriableStream.Substream
RetriableStream.State. winningSubstream
Null until committed.Fields in io.grpc.internal with type parameters of type RetriableStream.Substream Modifier and Type Field Description (package private) java.util.Collection<RetriableStream.Substream>
RetriableStream.State. activeHedges
Unmodifiable collection of all the active hedging substreams.(package private) java.util.Collection<RetriableStream.Substream>
RetriableStream.State. drainedSubstreams
Unmodifiable collection of all the open substreams that are drained.Methods in io.grpc.internal that return RetriableStream.Substream Modifier and Type Method Description private RetriableStream.Substream
RetriableStream. createSubstream(int previousAttemptCount, boolean isTransparentRetry)
Methods in io.grpc.internal with parameters of type RetriableStream.Substream Modifier and Type Method Description (package private) RetriableStream.State
RetriableStream.State. addActiveHedge(RetriableStream.Substream substream)
private java.lang.Runnable
RetriableStream. commit(RetriableStream.Substream winningSubstream)
private void
RetriableStream. commitAndRun(RetriableStream.Substream winningSubstream)
Calls commit() and if successful runs the post commit task.(package private) RetriableStream.State
RetriableStream.State. committed(RetriableStream.Substream winningSubstream)
private void
RetriableStream. drain(RetriableStream.Substream substream)
(package private) RetriableStream.State
RetriableStream.State. removeActiveHedge(RetriableStream.Substream substream)
(package private) RetriableStream.State
RetriableStream.State. replaceActiveHedge(RetriableStream.Substream oldOne, RetriableStream.Substream newOne)
void
RetriableStream.BufferEntry. runWith(RetriableStream.Substream substream)
Replays the buffer entry with the given stream.void
RetriableStream.StartEntry. runWith(RetriableStream.Substream substream)
(package private) RetriableStream.State
RetriableStream.State. substreamClosed(RetriableStream.Substream substream)
The given substream is closed.(package private) RetriableStream.State
RetriableStream.State. substreamDrained(RetriableStream.Substream substream)
The given substream is drained.Constructors in io.grpc.internal with parameters of type RetriableStream.Substream Constructor Description BufferSizeTracer(RetriableStream.Substream substream)
State(java.util.List<RetriableStream.BufferEntry> buffer, java.util.Collection<RetriableStream.Substream> drainedSubstreams, java.util.Collection<RetriableStream.Substream> activeHedges, RetriableStream.Substream winningSubstream, boolean cancelled, boolean passThrough, boolean hedgingFrozen, int hedgingAttemptCount)
Sublistener(RetriableStream.Substream substream)
Constructor parameters in io.grpc.internal with type arguments of type RetriableStream.Substream Constructor Description State(java.util.List<RetriableStream.BufferEntry> buffer, java.util.Collection<RetriableStream.Substream> drainedSubstreams, java.util.Collection<RetriableStream.Substream> activeHedges, RetriableStream.Substream winningSubstream, boolean cancelled, boolean passThrough, boolean hedgingFrozen, int hedgingAttemptCount)
-