diff --git a/src/main/java/nl/andrewl/email_indexer/gen/EmailIndexGenerator.java b/src/main/java/nl/andrewl/email_indexer/gen/EmailIndexGenerator.java index 86e4771..7179d10 100644 --- a/src/main/java/nl/andrewl/email_indexer/gen/EmailIndexGenerator.java +++ b/src/main/java/nl/andrewl/email_indexer/gen/EmailIndexGenerator.java @@ -57,7 +57,7 @@ public void generateIndex(EmailDataset dataset, Consumer messageConsumer messageConsumer.accept("Fetching page %d of %d".formatted(page, pageCount + 1)); pages.add(repo.findAll(page, itemsPerPage, false, null)); } - messageConsumer.accept("Fetching page %d".formatted(pageCount + 1)); + messageConsumer.accept("Fetching page %d of %d".formatted(pageCount + 1, pageCount + 1)); pages.add(repo.findAll(pageCount + 1, remainderItems, false, null)); Set threads = pages.stream() .map(result -> new Thread(() -> indexPage(result, repo, emailIndexWriter, messageConsumer)))