X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fquery%2FQueryCollectorImpl.java;h=0b6f6ef834411316255ac12e80f56faa3d3bdd93;hp=7bab1a77a9f6dbc60280e012a623566ddcb104e6;hb=4a2d5e0ab04119c571da0ec2d2289c71c55dc3f9;hpb=68e686fde705a331fe371bf1a0fbd07ae21be26e

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryCollectorImpl.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryCollectorImpl.java
index 7bab1a77a..0b6f6ef83 100644
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryCollectorImpl.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryCollectorImpl.java
@@ -42,6 +42,10 @@ class QueryCollectorImpl implements QueryProcessor.QueryCollector {
 	@Override
 	public void collect(int youngTarget, int allowedTimeInMs) {
 
+		// Flush listener registrations to prevent the collector from trashing
+		// listeners that are still queued up waiting to be registered.
+		queryProcessor.listening.sync();
+
 		long start = System.nanoTime();
 
 		// Refresh current size