netty_batch_write_proposal.java

    default int write(Supplier<?> msgs, int limit, Predicate<? super ChannelOutboundInvoker> stopCondition, Supplier<? extends ChannelPromise> promises, Consumer<? super ChannelFuture> futures) {
        for (int i = 0; i < limit; i++) {
            final boolean stop = stopCondition.test(this);
            if (stop) {
                return i;
            }
            final Object msg = msgs.get();
            assert msg != null;
            final ChannelPromise promise = promises.get();
            assert promise != null;
            futures.accept(write(msg, promise));
        }
        return limit;
    }