Skip to content

Commit 753d372

Browse files
csviriCopilot
andauthored
Potential fix for pull request finding
Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>
1 parent 569afe6 commit 753d372

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ public void addIndexers(Map<String, Function<R, List<String>>> indexers) {
258258

259259
@Override
260260
public Stream<R> byIndexStream(String indexName, String indexKey) {
261-
return sources.values().stream().map(s -> s.byIndex(indexName, indexKey)).flatMap(List::stream);
261+
return sources.values().stream().flatMap(s -> s.byIndexStream(indexName, indexKey));
262262
}
263263

264264
@Override

0 commit comments

Comments
 (0)