diff --git a/server/src/main/java/run/ikaros/server/search/IndicesServiceImpl.java b/server/src/main/java/run/ikaros/server/search/IndicesServiceImpl.java index 6540ee86..6e9f28b3 100644 --- a/server/src/main/java/run/ikaros/server/search/IndicesServiceImpl.java +++ b/server/src/main/java/run/ikaros/server/search/IndicesServiceImpl.java @@ -29,8 +29,7 @@ public IndicesServiceImpl( public Mono<Void> rebuildSubjectIndices() { return subjectRepository.findAll() .flatMap(ReactiveSubjectDocConverter::fromEntity) - .limitRate(10) - .buffer(50) + .collectList() .handle((subjectDocs, sink) -> { try { subjectSearchService.rebuild(subjectDocs);