wip

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

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

@@ -289,7 +289,7 @@ private Stream<R> mergeWithTempCacheForList(
 
       return stream.filter(filterResourceByPredicate(predicate));
     }
-    var tempResources = temporaryResourceCache.getResources();
+    var tempResources = new HashMap<>(temporaryResourceCache.getResources());
     if (tempResources.isEmpty()) {
       return stream.filter(filterResourceByPredicate(predicate));
     }
@@ -321,7 +321,7 @@ private Stream<R> mergeWithTempCacheForIndex(
     if (!comparableResourceVersions || temporaryResourceCache.isEmpty()) {
       return stream;
     }
-    var tempResources = temporaryResourceCache.getResources();
+    var tempResources = new HashMap<>(temporaryResourceCache.getResources());
     if (tempResources.isEmpty()) {
       return stream;
     }

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

@@ -15,6 +15,7 @@
  */
 package io.javaoperatorsdk.operator.processing.event.source.informer;
 
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Optional;
@@ -281,6 +282,6 @@ synchronized boolean isEmpty() {
   }
 
   synchronized Map<ResourceID, T> getResources() {
-    return new HashMap<>(cache);
+    return Collections.unmodifiableMap(cache);
   }
 }