Class ServletServerStream

java.lang.Object

io.grpc.internal.AbstractStream

io.grpc.internal.AbstractServerStream

io.grpc.servlet.ServletServerStream

All Implemented Interfaces:

MessageFramer.Sink, ServerStream, Stream

final class ServletServerStream
extends AbstractServerStream

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	ServletServerStream.ByteArrayWritableBuffer
private final class	ServletServerStream.GrpcWriteListener
(package private) final class	ServletServerStream.ServletTransportState
private final class	ServletServerStream.Sink
private static final class	ServletServerStream.TrailerSupplier

Nested classes/interfaces inherited from class AbstractServerStream

AbstractServerStream.TransportState

Field Summary

Fields

Modifier and Type	Field	Description
private final javax.servlet.AsyncContext	asyncCtx
private final Attributes	attributes
private final String	authority
private static final Logger	logger
private final InternalLogId	logId
private final javax.servlet.http.HttpServletResponse	resp
private final ServletServerStream.Sink	sink
private final ServletServerStream.ServletTransportState	transportState
private final AsyncServletOutputStreamWriter	writer

Constructor Summary

Constructors

Constructor	Description
ServletServerStream(javax.servlet.AsyncContext asyncCtx, StatsTraceContext statsTraceCtx, int maxInboundMessageSize, Attributes attributes, String authority, InternalLogId logId)

Method Summary

Modifier and Type	Method	Description
protected ServletServerStream.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.
(package private) static String	toHexString(byte[] bytes, int length)
protected ServletServerStream.ServletTransportState	transportState()	Obtain the transport state corresponding to this stream.
private void	writeHeadersToServletResponse(Metadata metadata)

Methods inherited from class AbstractServerStream

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

Methods inherited from class AbstractStream

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

Methods inherited from class Object

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

Methods inherited from interface Stream

flush, optimizeForDirectExecutor, request, setCompressor, setMessageCompression, writeMessage

Field Details

logger

private static final Logger logger

transportState

private final ServletServerStream.ServletTransportState transportState

sink

private final ServletServerStream.Sink sink

asyncCtx

private final javax.servlet.AsyncContext asyncCtx

resp

private final javax.servlet.http.HttpServletResponse resp

attributes

private final Attributes attributes

authority

private final String authority

logId

private final InternalLogId logId

writer

private final AsyncServletOutputStreamWriter writer

Constructor Details

ServletServerStream

ServletServerStream(javax.servlet.AsyncContext asyncCtx,
 StatsTraceContext statsTraceCtx,
 int maxInboundMessageSize,
 Attributes attributes,
 String authority,
 InternalLogId logId)
             throws IOException

Throws:

IOException

Method Details

transportState

protected ServletServerStream.ServletTransportState 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

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.

abstractServerStreamSink

protected ServletServerStream.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

writeHeadersToServletResponse

private void writeHeadersToServletResponse(Metadata metadata)

toHexString

static String toHexString(byte[] bytes,
 int length)