import org.simantics.db.impl.TableIntAllocatorAdapter;
import org.simantics.db.impl.TableSizeListener;
import org.simantics.db.impl.graph.ReadGraphImpl;
-import org.simantics.db.procedure.AsyncContextMultiProcedure;
-import org.simantics.db.procedure.AsyncMultiProcedure;
+import org.simantics.db.procedure.SyncContextMultiProcedure;
+import org.simantics.db.procedure.SyncMultiProcedure;
import org.simantics.db.procore.cluster.TableIntArraySet.Ints;
import gnu.trove.map.hash.TIntIntHashMap;
}
final public void foreachObject( ReadGraphImpl graph, final int objectIndex,
- final AsyncMultiProcedure<Resource> procedure, Modifier modifier) throws DatabaseException {
+ final SyncMultiProcedure<Resource> procedure, Modifier modifier) throws DatabaseException {
if (ClusterTraits.statementIndexIsDirect(objectIndex)) {
int key = modifier.execute(objectIndex);
procedure.execute(graph, new ResourceImpl(graph.getResourceSupport(), key));
}
final public <C> void foreachObject( ReadGraphImpl graph, final int objectIndex, C context,
- final AsyncContextMultiProcedure<C, Resource> procedure, Modifier modifier) throws DatabaseException {
+ final SyncContextMultiProcedure<C, Resource> procedure, Modifier modifier) throws DatabaseException {
if (ClusterTraits.statementIndexIsDirect(objectIndex)) {
int key = modifier.execute(objectIndex);
procedure.execute(graph, context, new ResourceImpl(graph.getResourceSupport(), key));
- procedure.finished(graph);
+ procedure.finished(graph, context);
// graph.dec();
return;
}