Uses of Class
io.grpc.internal.RetriableStream.Substream
Packages that use RetriableStream.Substream
-
Uses of RetriableStream.Substream in io.grpc.internal
Fields in io.grpc.internal declared as RetriableStream.SubstreamModifier and TypeFieldDescriptionprivate final RetriableStream.Substream
RetriableStream.BufferSizeTracer.substream
(package private) final RetriableStream.Substream
RetriableStream.Sublistener.substream
(package private) final RetriableStream.Substream
RetriableStream.State.winningSubstream
Null until committed.Fields in io.grpc.internal with type parameters of type RetriableStream.SubstreamModifier and TypeFieldDescription(package private) final Collection
<RetriableStream.Substream> RetriableStream.State.activeHedges
Unmodifiable collection of all the active hedging substreams.(package private) final Collection
<RetriableStream.Substream> RetriableStream.State.drainedSubstreams
Unmodifiable collection of all the open substreams that are drained.Methods in io.grpc.internal that return RetriableStream.SubstreamModifier and TypeMethodDescriptionprivate RetriableStream.Substream
RetriableStream.createSubstream
(int previousAttemptCount, boolean isTransparentRetry) Methods in io.grpc.internal with parameters of type RetriableStream.SubstreamModifier and TypeMethodDescription(package private) RetriableStream.State
RetriableStream.State.addActiveHedge
(RetriableStream.Substream substream) private 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.SubstreamModifierConstructorDescription(package private)
BufferSizeTracer
(RetriableStream.Substream substream) (package private)
State
(List<RetriableStream.BufferEntry> buffer, Collection<RetriableStream.Substream> drainedSubstreams, Collection<RetriableStream.Substream> activeHedges, RetriableStream.Substream winningSubstream, boolean cancelled, boolean passThrough, boolean hedgingFrozen, int hedgingAttemptCount) (package private)
Sublistener
(RetriableStream.Substream substream) Constructor parameters in io.grpc.internal with type arguments of type RetriableStream.SubstreamModifierConstructorDescription(package private)
State
(List<RetriableStream.BufferEntry> buffer, Collection<RetriableStream.Substream> drainedSubstreams, Collection<RetriableStream.Substream> activeHedges, RetriableStream.Substream winningSubstream, boolean cancelled, boolean passThrough, boolean hedgingFrozen, int hedgingAttemptCount)