@Test public void closeInvokesMessagesAvailableOnListener() { applicationThreadDeframer.close(); verify(mockDeframer).stopDelivery(); verifyNoMoreInteractions(mockDeframer); listener.runStoredProducer(); verify(mockDeframer).close(); }
@Override public void close() { deframer.stopDelivery(); storedListener.messagesAvailable( new InitializingMessageProducer( new Runnable() { @Override public void run() { deframer.close(); } })); }
ApplicationThreadDeframer implements Deframer, MessageDeframer.Listener { @Override public void close() { deframer.stopDelivery(); storedListener.messagesAvailable( new InitializingMessageProducer( new Runnable() { @Override public void run() { deframer.close(); } })); } }
ApplicationThreadDeframer implements Deframer, MessageDeframer.Listener { @Override public void close() { deframer.stopDelivery(); storedListener.messagesAvailable( new InitializingMessageProducer( new Runnable() { @Override public void run() { deframer.close(); } })); } ApplicationThreadDeframer(
      MessageDeframer.Listener listener,
      TransportExecutor transportExecutor,
      MessageDeframer deframer); }
ApplicationThreadDeframer implements Deframer, MessageDeframer.Listener { @Override public void close() { deframer.stopDelivery(); storedListener.messagesAvailable( new InitializingMessageProducer( new Runnable() { @Override public void run() { deframer.close(); } })); } ApplicationThreadDeframer(
      MessageDeframer.Listener listener,
      TransportExecutor transportExecutor,
      MessageDeframer deframer); @Override void setMaxInboundMessageSize(int messageSize); @Override void setDecompressor(Decompressor decompressor); @Override void setFullStreamDecompressor(GzipInflatingBuffer fullStreamDecompressor); @Override void request(final int numMessages); @Override void deframe(final ReadableBuffer data); @Override void closeWhenComplete(); @Override void close(); @Override void bytesRead(final int numBytes); @Override void messagesAvailable(StreamListener.MessageProducer producer); @Override void deframerClosed(final boolean hasPartialMessage); @Override void deframeFailed(final Throwable cause); }
ApplicationThreadDeframer implements Deframer, MessageDeframer.Listener { @Override public void close() { deframer.stopDelivery(); storedListener.messagesAvailable( new InitializingMessageProducer( new Runnable() { @Override public void run() { deframer.close(); } })); } ApplicationThreadDeframer(
      MessageDeframer.Listener listener,
      TransportExecutor transportExecutor,
      MessageDeframer deframer); @Override void setMaxInboundMessageSize(int messageSize); @Override void setDecompressor(Decompressor decompressor); @Override void setFullStreamDecompressor(GzipInflatingBuffer fullStreamDecompressor); @Override void request(final int numMessages); @Override void deframe(final ReadableBuffer data); @Override void closeWhenComplete(); @Override void close(); @Override void bytesRead(final int numBytes); @Override void messagesAvailable(StreamListener.MessageProducer producer); @Override void deframerClosed(final boolean hasPartialMessage); @Override void deframeFailed(final Throwable cause);  }