--- /dev/null
+package org.simantics.db.impl.graph;\r
+\r
+import org.simantics.db.Resource;\r
+import org.simantics.db.common.utils.Logger;\r
+import org.simantics.db.impl.query.IntProcedure;\r
+import org.simantics.db.impl.query.QuerySupport;\r
+import org.simantics.db.procedure.AsyncMultiProcedure;\r
+\r
+public class MultiIntProcedure implements IntProcedure {\r
+\r
+ final private AsyncMultiProcedure<Resource> procedure;\r
+ final private ReadGraphImpl impl;\r
+ final private QuerySupport support;\r
+ \r
+ public MultiIntProcedure(AsyncMultiProcedure<Resource> procedure, ReadGraphImpl impl, QuerySupport support) {\r
+ this.procedure = procedure;\r
+ this.impl = impl;\r
+ this.support = support;\r
+ }\r
+ \r
+ @Override\r
+ public void execute(ReadGraphImpl graph, int i) {\r
+ try {\r
+ procedure.execute(graph, support.getResource(i));\r
+ } catch (Throwable t2) {\r
+ Logger.defaultLogError(t2);\r
+ }\r
+ }\r
+\r
+ @Override\r
+ public void finished(ReadGraphImpl graph) {\r
+ try {\r
+ procedure.finished(graph);\r
+// impl.state.barrier.dec(this);\r
+ } catch (Throwable t2) {\r
+ Logger.defaultLogError(t2);\r
+ }\r
+ }\r
+\r
+ @Override\r
+ public void exception(ReadGraphImpl graph, Throwable t) {\r
+ try {\r
+ procedure.exception(graph, t);\r
+ } catch (Throwable t2) {\r
+ Logger.defaultLogError(t2);\r
+ }\r
+// impl.state.barrier.dec("ReadGraphSupportImpl.516");\r
+ }\r
+\r
+ @Override\r
+ public String toString() {\r
+ return "forEachObject with " + procedure;\r
+ }\r
+ \r
+}
\ No newline at end of file