class FlushConsolidationHandler extends ChannelDuplexHandler {

    @Override
    public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception {
        // Try to flush one last time if flushes are pending before close the channel.
        resetReadAndFlushIfNeeded(ctx);
        ctx.close(promise);
    }

    public  FlushConsolidationHandler();
    public  FlushConsolidationHandler(int explicitFlushAfterFlushes);
    public  FlushConsolidationHandler(int explicitFlushAfterFlushes, boolean consolidateWhenNoReadInProgress);

}