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)