class FlowControllingHttpContentProducer {

    public void newChunk(ByteBuf content) {
        stateMachine.handle(new ContentChunkEvent(content));
    }

    public  FlowControllingHttpContentProducer(
            Runnable askForMore,
            Runnable onCompleteAction,
            Consumer<Throwable> onTerminateAction,
            String loggingPrefix,
            long inactivityTimeoutMs,
            EventLoop eventLoop);

}