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.