Uses of Interface
io.grpc.internal.ClientStream

Packages that use ClientStream

Package	Description
io.grpc.inprocess	The in-process transport which is for when a server is in the same process as the client.
io.grpc.internal	Interfaces and implementations that are internal to gRPC.
io.grpc.netty	The main transport implementation based on Netty, for both the client and the server.

Uses of ClientStream in io.grpc.inprocess

Classes in io.grpc.inprocess that implement ClientStream

Modifier and Type	Class	Description
private class	InProcessTransport.InProcessStream.InProcessClientStream

Methods in io.grpc.inprocess that return ClientStream

Modifier and Type	Method	Description
private ClientStream	InProcessTransport.failedClientStream(StatsTraceContext statsTraceCtx, Status status)
ClientStream	InProcessTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)

Uses of ClientStream in io.grpc.internal

Classes in io.grpc.internal that implement ClientStream

Modifier and Type	Class	Description
class	AbstractClientStream	The abstract base class for ClientStream implementations.
private class	DelayedClientTransport.PendingStream
(package private) class	DelayedStream	A stream that queues requests before the transport is available, and delegates to a real stream implementation when the transport is available.
final class	FailingClientStream	An implementation of ClientStream that fails (by calling ClientStreamListener.closed(io.grpc.Status, io.grpc.internal.ClientStreamListener.RpcProgress, io.grpc.Metadata)) when started, and silently does nothing for the other operations.
(package private) class	ForwardingClientStream
class	NoopClientStream	An implementation of ClientStream that silently does nothing for the operations.
(package private) class	RetriableStream<ReqT>	A logical ClientStream that is retriable.

Fields in io.grpc.internal declared as ClientStream

Modifier and Type	Field	Description
private ClientStream	DelayedStream.realStream	Must hold this lock when setting.
private ClientStream	MetadataApplierImpl.returnedStream
private ClientStream	ClientCallImpl.stream
(package private) ClientStream	RetriableStream.Substream.stream

Fields in io.grpc.internal with type parameters of type ClientStream

Modifier and Type	Field	Description
(package private) Collection<ClientStream>	ManagedChannelImpl.UncommittedRetriableStreamsRegistry.uncommittedRetriableStreams

Methods in io.grpc.internal that return ClientStream

Modifier and Type	Method	Description
protected abstract ClientStream	ForwardingClientStream.delegate()
(package private) ClientStream	DelayedStream.getRealStream()
ClientStream	CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream	ClientCallImpl.ClientStreamProvider.newStream(MethodDescriptor<?,?> method, CallOptions callOptions, Metadata headers, Context context)
ClientStream	ClientTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)	Creates a new stream for sending messages to a remote end-point.
final ClientStream	DelayedClientTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)	If a LoadBalancer.SubchannelPicker is being, or has been provided via DelayedClientTransport.reprocess(io.grpc.LoadBalancer.SubchannelPicker), the last picker will be consulted.
ClientStream	FailingClientTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream	ForwardingConnectionClientTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream	InternalSubchannel.CallTracingTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
ClientStream	ManagedChannelImpl.ChannelStreamProvider.newStream(MethodDescriptor<?,?> method, CallOptions callOptions, Metadata headers, Context context)
(package private) abstract ClientStream	RetriableStream.newSubstream(Metadata headers, ClientStreamTracer.Factory tracerFactory, int previousAttempts, boolean isTransparentRetry)	Creates a new physical ClientStream that represents a retry/hedging attempt.
(package private) ClientStream	MetadataApplierImpl.returnStream()	Return a stream on which the RPC will run on.

Methods in io.grpc.internal with parameters of type ClientStream

Modifier and Type	Method	Description
private void	MetadataApplierImpl.finalizeWith(ClientStream stream)
private void	DelayedStream.setRealStream(ClientStream realStream)
(package private) final Runnable	DelayedStream.setStream(ClientStream stream)	Transfers all pending and future requests and mutations to the given stream.

Uses of ClientStream in io.grpc.netty

Classes in io.grpc.netty that implement ClientStream

Modifier and Type	Class	Description
(package private) class	NettyClientStream	Client stream for a Netty transport.

Methods in io.grpc.netty that return ClientStream

Modifier and Type	Method	Description
ClientStream	NettyClientTransport.newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)