MCPcopy Create free account
hub / github.com/crate/crate / move

Method move

libs/dex/src/main/java/io/crate/data/BatchIterator.java:159–159  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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++) {

Callers 15

moveToEndMethod · 0.80
acceptMethod · 0.80
collectMethod · 0.80
triggerConsumerMethod · 0.80
copyCheckpointToMethod · 0.80
executeMethod · 0.80
moveBlobAtomicMethod · 0.80

Calls

no outgoing calls