Package io.grpc.internal
Interface MessageDeframer.Listener
-
- All Known Implementing Classes:
AbstractClientStream.TransportState
,AbstractServerStream.TransportState
,AbstractStream.TransportState
,ApplicationThreadDeframerListener
,ForwardingDeframerListener
,Http2ClientStreamTransportState
,MigratingThreadDeframer.MigratingDeframerListener
,NettyClientStream.TransportState
,NettyServerStream.TransportState
,ServletServerStream.ServletTransportState
,ServletServerStream.ServletTransportState
,SquelchLateMessagesAvailableDeframerListener
- Enclosing class:
- MessageDeframer
public static interface MessageDeframer.Listener
A listener of deframing events. These methods will be invoked from the deframing thread.
-
-
Method Summary
All Methods Instance Methods Abstract 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
deframerClosed(boolean hasPartialMessage)
Called when the deframer closes.void
messagesAvailable(StreamListener.MessageProducer producer)
Called to deliver the next complete message.
-
-
-
Method Detail
-
bytesRead
void bytesRead(int numBytes)
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.
-
messagesAvailable
void messagesAvailable(StreamListener.MessageProducer producer)
Called to deliver the next complete message.- Parameters:
producer
- single message producer wrapping the message.
-
deframerClosed
void deframerClosed(boolean hasPartialMessage)
Called when the deframer closes.- Parameters:
hasPartialMessage
- whether the deframer contained an incomplete message at closing.
-
deframeFailed
void deframeFailed(java.lang.Throwable cause)
Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.- Parameters:
cause
- the actual failure
-
-