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;
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;
}
@Override
- public void load(ReadGraphImpl graph, int resource, int predicate, final Callback<ReadGraphImpl> callback) throws DatabaseException {
+ public void load(ReadGraphImpl graph, int resource, int predicate, final Consumer<ReadGraphImpl> callback) throws DatabaseException {
producePartialStatements(graph, resource, predicate, new AsyncProcedure<Object>() {
@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<ReadGraphImpl> callback) throws DatabaseException {
+ public void load(ReadGraphImpl graph, int resource, final Consumer<ReadGraphImpl> callback) throws DatabaseException {
produceAllStatements(graph, resource, new AsyncProcedure<Object>() {
@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);
}
});