Class 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.