Package io.grpc.servlet.jakarta
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 SerializingExecutortransportThreadExecutor-
Fields inherited from class io.grpc.internal.AbstractStream.TransportState
DEFAULT_ONREADY_THRESHOLD
-
-
Constructor Summary
Constructors Modifier Constructor Description privateServletTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidbytesRead(int numBytes)Called when the given number of bytes has been read from the input source of the deframer.voiddeframeFailed(java.lang.Throwable cause)Called when aMessageDeframer.deframe(ReadableBuffer)operation failed.voidrunOnTransportThread(java.lang.Runnable r)-
Methods inherited from class io.grpc.internal.AbstractServerStream.TransportState
complete, deframerClosed, inboundDataReceived, listener, onStreamAllocated, setListener, transportReportStatus
-
Methods inherited from class io.grpc.internal.AbstractStream.TransportState
closeDeframer, deframe, getStatsTraceContext, getTransportTracer, isStreamDeallocated, messagesAvailable, onSentBytes, onStreamDeallocated, requestMessagesFromDeframerForTesting, setDecompressor, setFullStreamDecompressor
-
-
-
-
Field Detail
-
transportThreadExecutor
private final SerializingExecutor transportThreadExecutor
-
-
Constructor Detail
-
ServletTransportState
private ServletTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer)
-
-
Method Detail
-
runOnTransportThread
public void runOnTransportThread(java.lang.Runnable r)
-
bytesRead
public void bytesRead(int numBytes)
Description copied from interface:MessageDeframer.ListenerCalled 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(java.lang.Throwable cause)
Description copied from interface:MessageDeframer.ListenerCalled when aMessageDeframer.deframe(ReadableBuffer)operation failed.- Parameters:
cause- the actual failure
-
-