X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.browsing.ui.graph.impl%2Fsrc%2Forg%2Fsimantics%2Fbrowsing%2Fui%2Fgraph%2Fimpl%2FLazyResourceQueryContainer.java;h=808193a18982d11d672a26d7984dc34f20146e06;hp=c694ba2e88291a52661a178438e60afc2ddc17be;hb=0d9b90834ce56b292c00b1a39850ed842c3e4d42;hpb=e5db6157fd8722c946613d4e46d7aaf6bfa92609 diff --git a/bundles/org.simantics.browsing.ui.graph.impl/src/org/simantics/browsing/ui/graph/impl/LazyResourceQueryContainer.java b/bundles/org.simantics.browsing.ui.graph.impl/src/org/simantics/browsing/ui/graph/impl/LazyResourceQueryContainer.java index c694ba2e8..808193a18 100644 --- a/bundles/org.simantics.browsing.ui.graph.impl/src/org/simantics/browsing/ui/graph/impl/LazyResourceQueryContainer.java +++ b/bundles/org.simantics.browsing.ui.graph.impl/src/org/simantics/browsing/ui/graph/impl/LazyResourceQueryContainer.java @@ -11,14 +11,13 @@ *******************************************************************************/ package org.simantics.browsing.ui.graph.impl; -import java.util.function.Consumer; - import org.simantics.browsing.ui.DataSource; import org.simantics.browsing.ui.NodeContext; import org.simantics.browsing.ui.NodeContext.PrimitiveQueryKey; import org.simantics.browsing.ui.PrimitiveQueryProcessor; import org.simantics.browsing.ui.PrimitiveQueryUpdater; import org.simantics.browsing.ui.graph.impl.request.ResourceQuery; +import org.simantics.db.AsyncReadGraph; import org.simantics.db.ReadGraph; import org.simantics.db.exception.DatabaseException; import org.simantics.db.procedure.Listener; @@ -113,19 +112,10 @@ public abstract class LazyResourceQueryContainer implements Container source = updater.getDataSource(ReadGraph.class); + final DataSource source = updater.getDataSource(AsyncReadGraph.class); assert(source != null); - source.schedule(new Consumer() { - - @Override - public void accept(ReadGraph source) { - - source.asyncRequest(query, procedure); - - } - - }); + source.schedule(graph -> graph.asyncRequest(query, procedure)); }