Package io.grpc.internal

Class SquelchLateMessagesAvailableDeframerListener

java.lang.Object

io.grpc.internal.ForwardingDeframerListener

io.grpc.internal.SquelchLateMessagesAvailableDeframerListener

All Implemented Interfaces:

MessageDeframer.Listener

final class SquelchLateMessagesAvailableDeframerListener
extends ForwardingDeframerListener

A delegating Listener that throws away notifications of messagesAvailable() after the deframer has closed or failed. This can be used by deframers that "abuse" the MessageProducer to run work on the app thread, to avoid breaking the normal invariant that there are no messages after deframing is complete. Since the producer may not be run, it must not hold resources or it should implement Closeable.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private final MessageDeframer.Listener	delegate

Constructor Summary

Constructors

Constructor	Description
SquelchLateMessagesAvailableDeframerListener(MessageDeframer.Listener delegate)

Method Summary

Modifier and Type	Method	Description
void	deframeFailed(Throwable cause)	Called when a MessageDeframer.deframe(ReadableBuffer) operation failed.
void	deframerClosed(boolean hasPartialMessage)	Called when the deframer closes.
protected MessageDeframer.Listener	delegate()
void	messagesAvailable(StreamListener.MessageProducer producer)	Called to deliver the next complete message.

Methods inherited from class io.grpc.internal.ForwardingDeframerListener

bytesRead

Methods inherited from class java.lang.Object

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

Field Details

delegate

private final MessageDeframer.Listener delegate

closed

private boolean closed

Constructor Details

SquelchLateMessagesAvailableDeframerListener

public SquelchLateMessagesAvailableDeframerListener(MessageDeframer.Listener delegate)

Method Details

delegate

protected MessageDeframer.Listener delegate()

Specified by:

delegate in class ForwardingDeframerListener

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

Overrides:

messagesAvailable in class ForwardingDeframerListener

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

Overrides:

deframerClosed in class ForwardingDeframerListener

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

Overrides:

deframeFailed in class ForwardingDeframerListener

Parameters:

cause - the actual failure