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%2FForEachObjectProcedure.java;h=85790c4de02cbcce7b5b2d4b209a43ae6782625b;hp=7bd7e7cb48c8f1375c7c22bb1fe5e3fcca2369de;hb=e19c37f84fd1ce2d946578f7c05f3e45444ba67a;hpb=969bd23cab98a79ca9101af33334000879fb60c5 diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectProcedure.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectProcedure.java index 7bd7e7cb4..85790c4de 100644 --- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectProcedure.java +++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/ForEachObjectProcedure.java @@ -1,44 +1,44 @@ -package org.simantics.db.impl; - -import org.simantics.db.AsyncReadGraph; -import org.simantics.db.RelationInfo; -import org.simantics.db.Resource; -import org.simantics.db.impl.query.QueryProcessor; -import org.simantics.db.procedure.AsyncMultiProcedure; - -public final class ForEachObjectProcedure implements AsyncMultiProcedure { - - public final int predicateKey; - public final int[] clusterKey; - public final int[] predicateReference; - public final RelationInfo info; - public final QueryProcessor processor; - public final ClusterI.CompleteTypeEnum completeType; - private final AsyncMultiProcedure user; - - public ForEachObjectProcedure(int predicateKey, RelationInfo info, QueryProcessor processor, AsyncMultiProcedure user) { - this.predicateKey = predicateKey; - this.completeType = ClusterTraitsBase.getCompleteTypeFromResourceKey(predicateKey); - this.info = info; - this.user = user; - this.processor = processor; - this.clusterKey = new int[32*8]; - this.predicateReference = new int[32*8]; - } - - @Override - public void execute(AsyncReadGraph graph, Resource result) { - user.execute(graph, result); - } - - @Override - public void finished(AsyncReadGraph graph) { - user.finished(graph); - } - - @Override - public void exception(AsyncReadGraph graph, Throwable throwable) { - user.exception(graph, throwable); - } - -} +package org.simantics.db.impl; + +import org.simantics.db.AsyncReadGraph; +import org.simantics.db.RelationInfo; +import org.simantics.db.Resource; +import org.simantics.db.impl.query.QueryProcessor; +import org.simantics.db.procedure.AsyncMultiProcedure; + +public final class ForEachObjectProcedure implements AsyncMultiProcedure { + + public final int predicateKey; + public final int[] clusterKey; + public final int[] predicateReference; + public final RelationInfo info; + public final QueryProcessor processor; + public final ClusterI.CompleteTypeEnum completeType; + private final AsyncMultiProcedure user; + + public ForEachObjectProcedure(int predicateKey, RelationInfo info, QueryProcessor processor, AsyncMultiProcedure user) { + this.predicateKey = predicateKey; + this.completeType = ClusterTraitsBase.getCompleteTypeFromResourceKey(predicateKey); + this.info = info; + this.user = user; + this.processor = processor; + this.clusterKey = new int[32*8]; + this.predicateReference = new int[32*8]; + } + + @Override + public void execute(AsyncReadGraph graph, Resource result) { + user.execute(graph, result); + } + + @Override + public void finished(AsyncReadGraph graph) { + user.finished(graph); + } + + @Override + public void exception(AsyncReadGraph graph, Throwable throwable) { + user.exception(graph, throwable); + } + +}