Skip to content

Commit

Permalink
Fixed bug in message.
Browse files Browse the repository at this point in the history
  • Loading branch information
andrewlalis committed Apr 15, 2022
1 parent 44e4ee6 commit 6b545b7
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public void generateIndex(EmailDataset dataset, Consumer<String> 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<Thread> threads = pages.stream()
.map(result -> new Thread(() -> indexPage(result, repo, emailIndexWriter, messageConsumer)))
Expand Down

0 comments on commit 6b545b7

Please sign in to comment.