Package io.grpc.internal
Class ForwardingDeframerListener
- java.lang.Object
-
- io.grpc.internal.ForwardingDeframerListener
-
- All Implemented Interfaces:
MessageDeframer.Listener
- Direct Known Subclasses:
MigratingThreadDeframer.MigratingDeframerListener
,SquelchLateMessagesAvailableDeframerListener
abstract class ForwardingDeframerListener extends java.lang.Object implements MessageDeframer.Listener
Forwards listener callbacks to a delegate.
-
-
Constructor Summary
Constructors Constructor Description ForwardingDeframerListener()
-
Method Summary
All Methods Instance Methods Abstract 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
deframerClosed(boolean hasPartialMessage)
Called when the deframer closes.protected abstract MessageDeframer.Listener
delegate()
void
messagesAvailable(StreamListener.MessageProducer producer)
Called to deliver the next complete message.
-
-
-
Method Detail
-
delegate
protected abstract MessageDeframer.Listener delegate()
-
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.- Specified by:
bytesRead
in interfaceMessageDeframer.Listener
- Parameters:
numBytes
- the number of bytes read from the deframer's input source.
-
messagesAvailable
public void messagesAvailable(StreamListener.MessageProducer producer)
Description copied from interface:MessageDeframer.Listener
Called to deliver the next complete message.- Specified by:
messagesAvailable
in interfaceMessageDeframer.Listener
- Parameters:
producer
- single message producer wrapping the message.
-
deframerClosed
public void deframerClosed(boolean hasPartialMessage)
Description copied from interface:MessageDeframer.Listener
Called when the deframer closes.- Specified by:
deframerClosed
in interfaceMessageDeframer.Listener
- Parameters:
hasPartialMessage
- whether the deframer contained an incomplete message at closing.
-
deframeFailed
public void deframeFailed(java.lang.Throwable cause)
Description copied from interface:MessageDeframer.Listener
Called when aMessageDeframer.deframe(ReadableBuffer)
operation failed.- Specified by:
deframeFailed
in interfaceMessageDeframer.Listener
- Parameters:
cause
- the actual failure
-
-