Class ServletServerStream.ServletTransportState

java.lang.Object

io.grpc.internal.AbstractStream.TransportState

io.grpc.internal.AbstractServerStream.TransportState

io.grpc.servlet.jakarta.ServletServerStream.ServletTransportState

All Implemented Interfaces:

ApplicationThreadDeframer.TransportExecutor, ApplicationThreadDeframerListener.TransportExecutor, MessageDeframer.Listener

Enclosing class:

ServletServerStream

final class ServletServerStream.ServletTransportState
extends AbstractServerStream.TransportState

Field Summary

Fields

Modifier and Type	Field	Description
private final SerializingExecutor	transportThreadExecutor

Fields inherited from class AbstractStream.TransportState

DEFAULT_ONREADY_THRESHOLD

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ServletTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer)

Method Summary

Modifier and Type	Method	Description
void	bytesRead(int numBytes)	Called when the given number of bytes has been read from the input source of the deframer.
void	deframeFailed(Throwable cause)	Called when a MessageDeframer.deframe(ReadableBuffer) operation failed.
void	runOnTransportThread(Runnable r)

Methods inherited from class AbstractServerStream.TransportState

complete, deframerClosed, inboundDataReceived, listener, onStreamAllocated, setListener, transportReportStatus

Methods inherited from class AbstractStream.TransportState

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

Methods inherited from class Object

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

Field Details

transportThreadExecutor

private final SerializingExecutor transportThreadExecutor

Constructor Details

ServletTransportState

private ServletTransportState(int maxMessageSize,
 StatsTraceContext statsTraceCtx,
 TransportTracer transportTracer)

Method Details

runOnTransportThread

public void runOnTransportThread(Runnable r)

bytesRead

public void bytesRead(int numBytes)

Description copied from interface: MessageDeframer.Listener

Called when the given number of bytes has been read from the input source of the deframer. This is typically used to indicate to the underlying transport that more data can be accepted.

Parameters:

numBytes - the number of bytes read from the deframer's input source.

deframeFailed

public void deframeFailed(Throwable cause)

Description copied from interface: MessageDeframer.Listener

Called when a MessageDeframer.deframe(ReadableBuffer) operation failed.

Parameters:

cause - the actual failure