Package io.grpc.netty

Class NettyServerStream

java.lang.Object

io.grpc.internal.AbstractStream

io.grpc.internal.AbstractServerStream

io.grpc.netty.NettyServerStream

All Implemented Interfaces:

MessageFramer.Sink, ServerStream, Stream

class NettyServerStream
extends AbstractServerStream

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private final Attributes	attributes
private final String	authority
private static final Logger	log
private final NettyServerStream.Sink	sink
private final NettyServerStream.TransportState	state
private final int	streamId
private final WriteQueue	writeQueue

Constructor Summary

Constructors

Constructor	Description
NettyServerStream(io.netty.channel.Channel channel, NettyServerStream.TransportState state, Attributes transportAttrs, String authority, StatsTraceContext statsTraceCtx)

Method Summary

Modifier and Type	Method	Description
protected NettyServerStream.Sink	abstractServerStreamSink()	Sink for transport to be called to perform outbound operations.
Attributes	getAttributes()	Attributes describing stream.
String	getAuthority()	Gets the authority this stream is addressed to.
int	streamId()	The HTTP/2 stream id, or -1 if not supported.
protected NettyServerStream.TransportState	transportState()	Obtain the transport state corresponding to this stream.

Methods inherited from class io.grpc.internal.AbstractServerStream

cancel, close, deliverFrame, framer, isReady, setDecompressor, setListener, setOnReadyThreshold, statsTraceContext, writeHeaders

Methods inherited from class io.grpc.internal.AbstractStream

endOfMessages, flush, onSendingBytes, optimizeForDirectExecutor, request, setCompressor, setMessageCompression, 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

log

private static final Logger log

sink

private final NettyServerStream.Sink sink

state

private final NettyServerStream.TransportState state

writeQueue

private final WriteQueue writeQueue

attributes

private final Attributes attributes

authority

private final String authority

streamId

private final int streamId

Constructor Details

NettyServerStream

public NettyServerStream(io.netty.channel.Channel channel,
 NettyServerStream.TransportState state,
 Attributes transportAttrs,
 String authority,
 StatsTraceContext statsTraceCtx)

Method Details

transportState

protected NettyServerStream.TransportState transportState()

Description copied from class: AbstractStream

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

Specified by:

transportState in class AbstractServerStream

abstractServerStreamSink

protected NettyServerStream.Sink abstractServerStreamSink()

Description copied from class: AbstractServerStream

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

Specified by:

abstractServerStreamSink in class AbstractServerStream

getAttributes

public Attributes getAttributes()

Description copied from interface: ServerStream

Attributes describing stream. This is inherited from the transport attributes, and used as the basis of ServerCall.getAttributes().

Specified by:

getAttributes in interface ServerStream

Overrides:

getAttributes in class AbstractServerStream

Returns:

Attributes container

getAuthority

public String getAuthority()

Description copied from interface: ServerStream

Gets the authority this stream is addressed to.

Specified by:

getAuthority in interface ServerStream

Overrides:

getAuthority in class AbstractServerStream

Returns:

the authority string. null if not available.

streamId

public int streamId()

Description copied from interface: ServerStream

The HTTP/2 stream id, or -1 if not supported.