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;
@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);
}