import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.TreeMap;
+import java.util.function.Consumer;
import org.simantics.databoard.Bindings;
import org.simantics.databoard.accessor.Accessor;
import org.simantics.db.request.WriteTraits;
import org.simantics.layer0.Layer0;
import org.simantics.utils.Development;
-import org.simantics.utils.datastructures.Callback;
import org.simantics.utils.datastructures.Pair;
import gnu.trove.map.hash.THashMap;
return new WriteGraphImpl(parent, processor, writeSupport, provider);
}
- @Override
- final public ReadGraphImpl withAsyncParent(CacheEntry parent2) {
- return new WriteGraphImpl(parent2, processor, writeSupport, provider);
- }
-
@Override
public ReadGraphImpl newRestart(ReadGraphImpl impl) {
@Override
public void asyncRequest(DelayedWrite request) {
assert (request != null);
- getWriteRequestScheduler().scheduleRequest(request, new Callback<DatabaseException>() {
-
- @Override
- public void run(DatabaseException parameter) {
- if(parameter != null)
- Logger.defaultLogError(parameter);
- }
-
+ getWriteRequestScheduler().scheduleRequest(request, e -> {
+ if(e != null)
+ Logger.defaultLogError(e);
}, null, Boolean.TRUE);
}
@Override
- public void asyncRequest(DelayedWrite request, Callback<DatabaseException> callback) {
+ public void asyncRequest(DelayedWrite request, Consumer<DatabaseException> callback) {
assert (request != null);
getWriteRequestScheduler().scheduleRequest(request, callback, null, Boolean.TRUE);
}
@Override
public void asyncRequest(final Write r) {
assert (r != null);
- getWriteRequestScheduler().scheduleRequest(r, new Callback<DatabaseException>() {
-
- @Override
- public void run(DatabaseException parameter) {
- if(parameter != null)
- Logger.defaultLogError(parameter);
- }
-
+ getWriteRequestScheduler().scheduleRequest(r, e -> {
+ if(e != null)
+ Logger.defaultLogError(e);
}, null, Boolean.TRUE);
}
@Override
- public void asyncRequest(Write request, Callback<DatabaseException> callback) {
+ public void asyncRequest(Write request, Consumer<DatabaseException> callback) {
assert (request != null);
getWriteRequestScheduler().scheduleRequest(request, callback, null, Boolean.TRUE);
}
@Override
public void asyncRequest(WriteOnly request) {
assert (request != null);
- getWriteRequestScheduler().scheduleRequest(request, new Callback<DatabaseException>() {
-
- @Override
- public void run(DatabaseException parameter) {
- if(parameter != null)
- Logger.defaultLogError(parameter);
- }
-
+ getWriteRequestScheduler().scheduleRequest(request, e -> {
+ if(e != null)
+ Logger.defaultLogError(e);
}, null, Boolean.TRUE);
}
@Override
- public void asyncRequest(WriteOnly request, Callback<DatabaseException> callback) {
+ public void asyncRequest(WriteOnly request, Consumer<DatabaseException> callback) {
assert (request != null);
getWriteRequestScheduler().scheduleRequest(request, callback, null, Boolean.TRUE);
}
Layer0 b = getBuiltins();
initBuiltinValues(b);
+ if(resource.toString().equals("[id=$319492]") && predicate.toString().equals("[id=$235477]"))
+ System.err.println("foobar2");
+
+
Statement literalStatement = getPossibleStatement(resource, predicate);
if(literalStatement != null && resource.equals(literalStatement.getSubject())) {