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%2FTransientGraph.java;h=f4e722fe5adea864496e4a7864197ae7fb6e877d;hp=3a552ed194a44877ce20f9e4e5e37fb7668df1f3;hb=56a799c9b7d395cefb59e101cd0f7ce8d68f88e6;hpb=43b5be1b099b479a20ac36e3bf2c6703242f068d diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/TransientGraph.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/TransientGraph.java index 3a552ed19..f4e722fe5 100644 --- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/TransientGraph.java +++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/TransientGraph.java @@ -19,6 +19,7 @@ import java.util.Arrays; import java.util.Collection; import java.util.HashSet; import java.util.LinkedList; +import java.util.function.Consumer; import org.simantics.databoard.Bindings; import org.simantics.databoard.binding.Binding; @@ -48,7 +49,6 @@ import org.simantics.db.procedure.AsyncProcedure; import org.simantics.db.request.Write; import org.simantics.db.request.WriteOnly; import org.simantics.db.service.SerialisationSupport; -import org.simantics.utils.datastructures.Callback; import gnu.trove.list.array.TIntArrayList; import gnu.trove.map.hash.TIntObjectHashMap; @@ -867,34 +867,34 @@ public class TransientGraph implements VirtualGraphImpl, VirtualGraphContext { } @Override - public void load(ReadGraphImpl graph, int resource, int predicate, final Callback callback) throws DatabaseException { + public void load(ReadGraphImpl graph, int resource, int predicate, final Consumer callback) throws DatabaseException { producePartialStatements(graph, resource, predicate, new AsyncProcedure() { @Override public void execute(AsyncReadGraph graph, Object result) { - callback.run((ReadGraphImpl)graph); + callback.accept((ReadGraphImpl)graph); } @Override public void exception(AsyncReadGraph graph, Throwable throwable) { - callback.run((ReadGraphImpl)graph); + callback.accept((ReadGraphImpl)graph); } }); } @Override - public void load(ReadGraphImpl graph, int resource, final Callback callback) throws DatabaseException { + public void load(ReadGraphImpl graph, int resource, final Consumer callback) throws DatabaseException { produceAllStatements(graph, resource, new AsyncProcedure() { @Override public void execute(AsyncReadGraph graph, Object result) { - callback.run((ReadGraphImpl)graph); + callback.accept((ReadGraphImpl)graph); } @Override public void exception(AsyncReadGraph graph, Throwable throwable) { - callback.run((ReadGraphImpl)graph); + callback.accept((ReadGraphImpl)graph); } });