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
-
Field Summary
FieldsFields inherited from class io.grpc.internal.AbstractStream.TransportState
DEFAULT_ONREADY_THRESHOLD
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
ServletTransportState
(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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 aMessageDeframer.deframe(ReadableBuffer)
operation failed.void
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 Details
-
transportThreadExecutor
-
-
Constructor Details
-
ServletTransportState
private ServletTransportState(int maxMessageSize, StatsTraceContext statsTraceCtx, TransportTracer transportTracer)
-
-
Method Details
-
runOnTransportThread
-
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
Description copied from interface:MessageDeframer.Listener
Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.- Parameters:
cause
- the actual failure
-