From 6b545b74846194f0842560d22ff36e121a31b4ce Mon Sep 17 00:00:00 2001 From: Andrew Lalis Date: Fri, 15 Apr 2022 12:47:47 +0200 Subject: [PATCH] Fixed bug in message. --- .../java/nl/andrewl/email_indexer/gen/EmailIndexGenerator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)))