### Question:
FlowControllingHttpContentProducer { public void newChunk(ByteBuf content) { stateMachine.handle(new ContentChunkEvent(content)); } FlowControllingHttpContentProducer(
            Runnable askForMore,
            Runnable onCompleteAction,
            Consumer<Throwable> onTerminateAction,
            String loggingPrefix,
            long inactivityTimeoutMs,
            EventLoop eventLoop); void newChunk(ByteBuf content); void lastHttpContent(); void channelException(Throwable cause); void channelInactive(Throwable cause); void tearDownResources(Throwable cause); void request(long n); void onSubscribed(Subscriber<? super ByteBuf> subscriber); void unsubscribe(); long emittedBytes(); long emittedChunks(); long receivedBytes(); long receivedChunks();  }### Answer:
@Test public void contentEventInBufferingState() { setUpAndRequest(5); verify(askForMore).run(); producer.newChunk(contentChunk1); verify(askForMore, times(1)).run(); producer.newChunk(contentChunk2); verify(askForMore, times(1)).run(); }