Class Http2ClientStreamTransportState

java.lang.Object

io.grpc.internal.AbstractStream.TransportState

io.grpc.internal.AbstractClientStream.TransportState

io.grpc.internal.Http2ClientStreamTransportState

All Implemented Interfaces:

io.grpc.internal.ApplicationThreadDeframerListener.TransportExecutor, MessageDeframer.Listener

public abstract class Http2ClientStreamTransportState
extends AbstractClientStream.TransportState

Base implementation for client streams using HTTP2 as the transport.

Field Summary

Fields inherited from class AbstractStream.TransportState

DEFAULT_ONREADY_THRESHOLD

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Http2ClientStreamTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer, CallOptions options)

Method Summary

Modifier and Type	Method	Description
protected abstract void	http2ProcessingFailed(Status status, boolean stopDelivery, Metadata trailers)	Called to process a failure in HTTP/2 processing.
protected void	transportDataReceived(ReadableBuffer frame, boolean endOfStream)	Called by subclasses whenever a data frame is received from the transport.
protected void	transportHeadersReceived(Metadata headers)	Called by subclasses whenever Headers are received from the transport.
protected void	transportTrailersReceived(Metadata trailers)	Called by subclasses for the terminal trailer metadata on a stream.

Methods inherited from class AbstractClientStream.TransportState

deframerClosed, inboundDataReceived, inboundHeadersReceived, inboundTrailersReceived, isOutboundClosed, listener, setListener, transportReportStatus, transportReportStatus

Methods inherited from class AbstractStream.TransportState

closeDeframer, deframe, getStatsTraceContext, getTransportTracer, isStreamDeallocated, messagesAvailable, onSentBytes, onStreamAllocated, onStreamDeallocated, requestMessagesFromDeframerForTesting, setDecompressor, setFullStreamDecompressor

Methods inherited from class Object

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

Methods inherited from interface io.grpc.internal.ApplicationThreadDeframerListener.TransportExecutor

runOnTransportThread

Methods inherited from interface MessageDeframer.Listener

bytesRead, deframeFailed

Constructor Details

Http2ClientStreamTransportState

protected Http2ClientStreamTransportState(int maxMessageSize,
 StatsTraceContext statsTraceCtx,
 TransportTracer transportTracer,
 CallOptions options)

Method Details

http2ProcessingFailed

protected abstract void http2ProcessingFailed(Status status,
 boolean stopDelivery,
 Metadata trailers)

Called to process a failure in HTTP/2 processing. It should notify the transport to cancel the stream and call transportReportStatus().

transportHeadersReceived

protected void transportHeadersReceived(Metadata headers)

Called by subclasses whenever Headers are received from the transport.

Parameters:

headers - the received headers

transportDataReceived

protected void transportDataReceived(ReadableBuffer frame,
 boolean endOfStream)

Called by subclasses whenever a data frame is received from the transport.

Parameters:

frame - the received data frame

endOfStream - true if there will be no more data received for this stream

transportTrailersReceived

protected void transportTrailersReceived(Metadata trailers)

Called by subclasses for the terminal trailer metadata on a stream.

Parameters:

trailers - the received terminal trailer metadata