Package io.grpc.servlet
Class ServletServerStream.ServletTransportState
- java.lang.Object
-
- io.grpc.internal.AbstractStream.TransportState
-
- io.grpc.internal.AbstractServerStream.TransportState
-
- io.grpc.servlet.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 SerializingExecutor
transportThreadExecutor
-
Fields inherited from class io.grpc.internal.AbstractStream.TransportState
DEFAULT_ONREADY_THRESHOLD
-
-
Constructor Summary
Constructors Modifier Constructor Description private
ServletTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer)
-
Method Summary
All Methods Instance Methods Concrete Methods 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(java.lang.Throwable cause)
Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.void
runOnTransportThread(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.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(java.lang.Throwable cause)
Description copied from interface:MessageDeframer.Listener
Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.- Parameters:
cause
- the actual failure
-
-