X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fquery%2FQueryListening.java;h=a26460a47d733538aa0e3ec287541be76eee6c4e;hb=beffc2723bcc9b4219fc0b915f27542b0c159af9;hp=dd410b4ce7e8c57fba7e86d94a30dbb7b9ec1e9f;hpb=bb61be97905f72c01fd99e21c263546c88edc5f7;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryListening.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryListening.java
index dd410b4ce..a26460a47 100644
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryListening.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryListening.java
@@ -293,7 +293,7 @@ public class QueryListening {
         if(base == null) return;
 
         consumer.accept(() -> {
-            ListenerEntry entry = addedEntries.get(base);
+            ListenerEntry entry = addedEntries.remove(base);
             if(entry != null) entry.setLastKnown(result);
         });
 
@@ -413,7 +413,7 @@ public class QueryListening {
 
     }
 
-    public void fireListeners(WriteGraphImpl graph) {
+    public void fireListeners(ReadGraphImpl graph) {
 
         assert (!processor.updating);
         assert (!processor.cache.collecting);