Method triggerConsumer

server/src/main/java/io/crate/session/Cursor.java:192–279

(RowConsumer consumer, BatchIterator<Row> fullResult, ScrollMode mode, long lCount)

    }

    private void triggerConsumer(RowConsumer consumer, BatchIterator<Row> fullResult, ScrollMode mode, long lCount) {
        // Long.MAX_VALUE is used as "ALL"
        if (lCount == Long.MAX_VALUE) {
            lCount = Integer.MAX_VALUE;
        }
        if (lCount == - Long.MAX_VALUE) {
            lCount = - Integer.MAX_VALUE;
        }
        int count = (int) lCount;
        boolean moveForward = ((mode == ScrollMode.MOVE || mode == ScrollMode.RELATIVE) && count >= 0) ||
                              mode == ScrollMode.ABSOLUTE && count > cursorPosition;
        if (!moveForward && !scroll) {
            throw new IllegalArgumentException("Cannot move backward if cursor was created with NO SCROLL");
        }
        resetCursorToMaxBufferedRowsPlus1();

        if (mode == ScrollMode.ABSOLUTE) {
            // Absolute jumps to a position and returns that row (or none if before start; after end)

            if (count < rows.size()) {
                cursorPosition = Math.max(count, 0);
                consumer.accept(bufferedRowOrNone(count - 1), null);
            } else {
                int steps = count - cursorPosition + 1;
                fullResult.move(steps, row -> {}, err -> {
                    if (err == null) {
                        if (count > rows.size()) {
                            consumer.accept(null, new IllegalArgumentException(String.format(Locale.ENGLISH,
                                                  "Cannot return row: %s, total rows: %s", count, rows.size())));
                        } else {
                            consumer.accept(bufferedRowOrNone(count - 1), null);
                            cursorPosition = count;
                        }
                    } else {
                        consumer.accept(null, err);
                    }
                });
            }
        } else if (mode == ScrollMode.RELATIVE) {
            // Relative jumps to a position relative to cursorPosition
            // and returns that row (or none if before start; after end)

            int newCursorPosition = newCursorPosition(count);
            if (newCursorPosition < rows.size()) {
                cursorPosition = Math.max(newCursorPosition, 0);
                consumer.accept(bufferedRowOrNone(cursorPosition - 1), null);
            } else {
                int steps = newCursorPosition - cursorPosition + 1;
                fullResult.move(steps, row -> {}, err -> {
                    if (err == null) {
                        cursorPosition = newCursorPosition;
                        consumer.accept(bufferedRowOrNone(cursorPosition - 1), null);
                    } else {
                        consumer.accept(null, err);
                    }
                });
            }
        } else if (moveForward) {