Uses of Interface
io.grpc.internal.ClientStream
Packages that use ClientStream
Package
Description
The in-process transport which is for when a server is in the same process as the client.
Interfaces and implementations that are internal to gRPC.
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 ClientStreamModifier and TypeClassDescriptionprivate class
Methods in io.grpc.inprocess that return ClientStreamModifier and TypeMethodDescriptionprivate ClientStream
InProcessTransport.failedClientStream
(StatsTraceContext statsTraceCtx, Status status) InProcessTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) -
Uses of ClientStream in io.grpc.internal
Classes in io.grpc.internal that implement ClientStreamModifier and TypeClassDescriptionclass
The abstract base class forClientStream
implementations.private class
(package private) class
A stream that queues requests before the transport is available, and delegates to a real stream implementation when the transport is available.final class
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
class
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 ClientStreamModifier and TypeFieldDescriptionprivate 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 ClientStreamModifier and TypeFieldDescription(package private) Collection
<ClientStream> ManagedChannelImpl.UncommittedRetriableStreamsRegistry.uncommittedRetriableStreams
Methods in io.grpc.internal that return ClientStreamModifier and TypeMethodDescriptionprotected abstract ClientStream
ForwardingClientStream.delegate()
(package private) ClientStream
DelayedStream.getRealStream()
CallCredentialsApplyingTransportFactory.CallCredentialsApplyingTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) ClientCallImpl.ClientStreamProvider.newStream
(MethodDescriptor<?, ?> method, CallOptions callOptions, Metadata headers, Context context) 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 aLoadBalancer.SubchannelPicker
is being, or has been provided viaDelayedClientTransport.reprocess(io.grpc.LoadBalancer.SubchannelPicker)
, the last picker will be consulted.FailingClientTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) ForwardingConnectionClientTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) InternalSubchannel.CallTracingTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers) 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 ClientStreamModifier and TypeMethodDescriptionprivate 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 ClientStreamModifier and TypeClassDescription(package private) class
Client stream for a Netty transport.Methods in io.grpc.netty that return ClientStreamModifier and TypeMethodDescriptionNettyClientTransport.newStream
(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions, ClientStreamTracer[] tracers)