fix: 修复初始化查询索引时无法初始化所有条目的问题 (#725)

* fix: 修复初始化查询索引时无法初始化所有条目的问题 * Revert "fix: 修复初始化查询索引时无法初始化所有条目的问题" This reverts commit 520299d. * fix: 去掉速率控制
ikaros-dev · Nov 10, 2024 · cf1cab4 · cf1cab4
1 parent e76debf
commit cf1cab4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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);