Package io.grpc.netty

Class NettyClientStream

java.lang.Object

io.grpc.internal.AbstractStream

io.grpc.internal.AbstractClientStream

io.grpc.netty.NettyClientStream

All Implemented Interfaces:

ClientStream, MessageFramer.Sink, Stream

class NettyClientStream
extends AbstractClientStream

Client stream for a Netty transport. Must only be called from the sending application thread.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	NettyClientStream.Sink
static class	NettyClientStream.TransportState	This should only be called from the transport thread.

Field Summary

Fields

Modifier and Type	Field	Description
private io.netty.util.AsciiString	authority
private final MethodDescriptor<?,?>	method
private static final InternalMethodDescriptor	methodDescriptorAccessor
private final io.netty.util.AsciiString	scheme
private final NettyClientStream.Sink	sink
private final NettyClientStream.TransportState	state
private final io.netty.util.AsciiString	userAgent
private final WriteQueue	writeQueue

Constructor Summary

Constructors

Constructor	Description
NettyClientStream(NettyClientStream.TransportState state, MethodDescriptor<?,?> method, Metadata headers, io.netty.channel.Channel channel, io.netty.util.AsciiString authority, io.netty.util.AsciiString scheme, io.netty.util.AsciiString userAgent, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions callOptions, boolean useGetForSafeMethods)

Method Summary

Modifier and Type	Method	Description
protected NettyClientStream.Sink	abstractClientStreamSink()	Sink for transport to be called to perform outbound operations.
Attributes	getAttributes()	Attributes that the stream holds at the current moment.
void	setAuthority(String authority)	Override the default authority with authority.
protected NettyClientStream.TransportState	transportState()	Obtain the transport state corresponding to this stream.

Methods inherited from class io.grpc.internal.AbstractClientStream

appendTimeoutInsight, cancel, deliverFrame, framer, getTransportTracer, halfClose, isReady, setDeadline, setDecompressorRegistry, setFullStreamDecompression, setMaxInboundMessageSize, setMaxOutboundMessageSize, shouldBeCountedForInUse, start

Methods inherited from class io.grpc.internal.AbstractStream

endOfMessages, flush, onSendingBytes, optimizeForDirectExecutor, request, setCompressor, setMessageCompression, setOnReadyThreshold, writeMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.grpc.internal.Stream

flush, optimizeForDirectExecutor, request, setCompressor, setMessageCompression, writeMessage

Field Details

methodDescriptorAccessor

private static final InternalMethodDescriptor methodDescriptorAccessor

sink

private final NettyClientStream.Sink sink

state

private final NettyClientStream.TransportState state

writeQueue

private final WriteQueue writeQueue

method

private final MethodDescriptor<?,?> method

authority

private io.netty.util.AsciiString authority

scheme

private final io.netty.util.AsciiString scheme

userAgent

private final io.netty.util.AsciiString userAgent

Constructor Details

NettyClientStream

NettyClientStream(NettyClientStream.TransportState state,
 MethodDescriptor<?,?> method,
 Metadata headers,
 io.netty.channel.Channel channel,
 io.netty.util.AsciiString authority,
 io.netty.util.AsciiString scheme,
 io.netty.util.AsciiString userAgent,
 StatsTraceContext statsTraceCtx,
 TransportTracer transportTracer,
 CallOptions callOptions,
 boolean useGetForSafeMethods)

Method Details

transportState

protected NettyClientStream.TransportState transportState()

Description copied from class: AbstractClientStream

Obtain the transport state corresponding to this stream. Each stream must have its own unique transport state.

Specified by:

transportState in class AbstractClientStream

abstractClientStreamSink

protected NettyClientStream.Sink abstractClientStreamSink()

Description copied from class: AbstractClientStream

Sink for transport to be called to perform outbound operations. Each stream must have its own unique sink.

Specified by:

abstractClientStreamSink in class AbstractClientStream

setAuthority

public void setAuthority(String authority)

Description copied from interface: ClientStream

Override the default authority with authority. May only be called before ClientStream.start(io.grpc.internal.ClientStreamListener).

getAttributes

public Attributes getAttributes()

Description copied from interface: ClientStream

Attributes that the stream holds at the current moment. Thread-safe and can be called at any time, although some attributes are there only after a certain point.