Move the batchIterator by steps utilizing #moveNext() @param onNext called for each successful moveNext. @param onFinish called after steps, if exhausted, or on error.
(int steps, Consumer<T> onNext, Consumer<Throwable> onFinish)
| 157 | * @param onFinish called after {@code steps}, if exhausted, or on error. |
| 158 | */ |
| 159 | default void move(int steps, Consumer<T> onNext, Consumer<Throwable> onFinish) { |
| 160 | assert steps >= 0 : "steps must be positive"; |
| 161 | try { |
| 162 | for (int i = 0; i < steps; i++) { |
no outgoing calls