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

chillaq · gthea · web-flow · commit 6b51bcbe79ff · 2025-04-30T08:06:03.000-07:00
Co-authored-by: gthea &lt;theagaston@gmail.com&gt;
diff --git a/client/src/main/java/io/split/engine/segments/SegmentSynchronizationTaskImp.java b/client/src/main/java/io/split/engine/segments/SegmentSynchronizationTaskImp.java
@@ -140,8 +140,8 @@ public boolean isRunning() {
     }
 
     public void fetchAll(boolean addCacheHeader) {
-        _splitCacheConsumer.getSegments().forEach(this::initialize);
-        _ruleBasedSegmentCacheConsumer.getSegments().forEach(this::initialize);
+        Set<String> names = getSegmentNames();
+        names.forEach(this::initialize);
         for (Map.Entry<String, SegmentFetcher> entry : _segmentFetchers.entrySet()) {
             SegmentFetcher fetcher = entry.getValue();
 

Original file line number	Diff line number	Diff line change
`@@ -140,8 +140,8 @@ public boolean isRunning() {`
`140`	`140`	`}`
`141`	`141`
`142`	`142`	`public void fetchAll(boolean addCacheHeader) {`
`143`		`- _splitCacheConsumer.getSegments().forEach(this::initialize);`
`144`		`- _ruleBasedSegmentCacheConsumer.getSegments().forEach(this::initialize);`
	`143`	`+ Set<String> names = getSegmentNames();`
	`144`	`+ names.forEach(this::initialize);`
`145`	`145`	`for (Map.Entry<String, SegmentFetcher> entry : _segmentFetchers.entrySet()) {`
`146`	`146`	`SegmentFetcher fetcher = entry.getValue();`
`147`	`147`