Skip to content

Commit 871a336

Browse files
committed
wip
Signed-off-by: Attila Mészáros <a_meszaros@apple.com>
1 parent afccf3e commit 871a336

2 files changed

Lines changed: 2 additions & 5 deletions

File tree

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -107,10 +107,6 @@ private void initSources() {
107107
}
108108
}
109109

110-
C configuration() {
111-
return configuration;
112-
}
113-
114110
public void changeNamespaces(Set<String> namespaces) {
115111
var sourcesToRemove =
116112
sources.keySet().stream().filter(k -> !namespaces.contains(k)).collect(Collectors.toSet());

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -390,7 +390,8 @@ public Stream<ResourceID> keys() {
390390
}
391391
var managerKeys = manager().keys().collect(Collectors.toSet());
392392
var tempKeys = temporaryResourceCache.getResources().keySet();
393-
return Stream.concat(managerKeys.stream(), tempKeys.stream().filter(k -> !managerKeys.contains(k)));
393+
return Stream.concat(
394+
managerKeys.stream(), tempKeys.stream().filter(k -> !managerKeys.contains(k)));
394395
}
395396

396397
@Override

0 commit comments

Comments
 (0)