Method fetch

server/src/main/java/io/crate/session/Cursor.java:124–145

(RowConsumer consumer, ScrollMode scrollMode, long count)

    }

    public void fetch(RowConsumer consumer, ScrollMode scrollMode, long count) {
        if (queryIterator.isDone()) {
            try {
                BatchIterator<Row> bi = queryIterator.join();
                triggerConsumer(consumer, new BufferingBatchIterator(bi), scrollMode, count);
            } catch (Throwable t) {
                consumer.accept(null, t);
            }
        } else {
            queryIterator.whenComplete((bi, err) -> {
                if (err == null) {
                    try {
                        triggerConsumer(consumer, new BufferingBatchIterator(bi), scrollMode, count);
                    } catch (Throwable t) {
                        consumer.accept(null, t);
                    }
                } else {
                    consumer.accept(null, err);
                }
            });
        }
    }

    private class BufferingBatchIterator extends ForwardingBatchIterator<Row> {