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 forClientStream
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.class
FailingClientStream
An implementation ofClientStream
that fails (by callingClientStreamListener.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 ofClientStream
that silently does nothing for the operations.(package private) class
RetriableStream<ReqT>
A logicalClientStream
that is retriable.Fields in io.grpc.internal declared as ClientStream Modifier and Type Field Description private ClientStream
DelayedStream. realStream
Must holdthis
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) java.util.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.ClientStream
DelayedClientTransport. newStream(MethodDescriptor<?,?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)
If aLoadBalancer.SubchannelPicker
is being, or has been provided viaDelayedClientTransport.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) java.lang.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)
-