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 Object
implements MessageDeframer.Listener

Forwards listener callbacks to a delegate.

Constructor Summary

Constructors

Constructor	Description
ForwardingDeframerListener()

Method Summary

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(Throwable cause)	Called when a MessageDeframer.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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ForwardingDeframerListener

ForwardingDeframerListener()

Method Details

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 interface MessageDeframer.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 interface MessageDeframer.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 interface MessageDeframer.Listener

Parameters:

hasPartialMessage - whether the deframer contained an incomplete message at closing.

deframeFailed

public void deframeFailed(Throwable cause)

Description copied from interface: MessageDeframer.Listener

Called when a MessageDeframer.deframe(ReadableBuffer) operation failed.

Specified by:

deframeFailed in interface MessageDeframer.Listener

Parameters:

cause - the actual failure