Skip to content

Commit bca3958

Browse files
committed
polish
1 parent 721fc2d commit bca3958

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

client/src/main/java/io/split/engine/segments/SegmentSynchronizationTaskImp.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -161,8 +161,8 @@ public void fetchAll(boolean addCacheHeader) {
161161
}
162162

163163
public boolean fetchAllSynchronous() {
164-
_splitCacheConsumer.getSegments().forEach(this::initialize);
165-
_ruleBasedSegmentCacheConsumer.getSegments().forEach(this::initialize);
164+
Set<String> names = getSegmentNames();
165+
names.forEach(this::initialize);
166166
List<Future<Boolean>> segmentFetchExecutions = _segmentFetchers.entrySet()
167167
.stream().map(e -> _scheduledExecutorService.submit(e.getValue()::runWhitCacheHeader))
168168
.collect(Collectors.toList());

0 commit comments

Comments
 (0)