X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.common%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fcommon%2Frequest%2FDelayedWriteRequest.java;h=d634cb71502281fce1eb8521794a2d62397658d5;hb=1cd631466bc35e05bc585999b2f325f148cd5629;hp=7194d9a955281608767d3dbde532e9399f6e2c63;hpb=0ae2b770234dfc3cbb18bd38f324125cf0faca07;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.db.common/src/org/simantics/db/common/request/DelayedWriteRequest.java b/bundles/org.simantics.db.common/src/org/simantics/db/common/request/DelayedWriteRequest.java index 7194d9a95..d634cb715 100644 --- a/bundles/org.simantics.db.common/src/org/simantics/db/common/request/DelayedWriteRequest.java +++ b/bundles/org.simantics.db.common/src/org/simantics/db/common/request/DelayedWriteRequest.java @@ -17,13 +17,11 @@ import org.simantics.db.AsyncRequestProcessor; import org.simantics.db.ChangeSetIdentifier; import org.simantics.db.Operation; import org.simantics.db.RequestProcessor; -import org.simantics.db.VirtualGraph; import org.simantics.db.exception.DatabaseException; import org.simantics.db.procedure.Procedure; import org.simantics.db.request.DelayedWrite; import org.simantics.db.request.UndoTraits; import org.simantics.db.request.WriteInterface; -import org.simantics.utils.datastructures.Callback; /** @@ -75,16 +73,6 @@ import org.simantics.utils.datastructures.Callback; */ public abstract class DelayedWriteRequest implements DelayedWrite, UndoTraits, WriteInterface { - @Override - public VirtualGraph getProvider() { - return null; - } - - @Override - public UndoTraits getUndoTraits() { - return this; - } - @Override public ChangeSetIdentifier getIdentifier() { return null; @@ -101,14 +89,9 @@ public abstract class DelayedWriteRequest implements DelayedWrite, UndoTraits, W @Override public void request(AsyncRequestProcessor processor, final Procedure procedure) { - processor.asyncRequest(this, new Callback() { - - @Override - public void run(DatabaseException parameter) { - if(parameter != null) procedure.exception(parameter); - else procedure.execute(null); - } - + processor.asyncRequest(this, parameter -> { + if(parameter != null) procedure.exception(parameter); + else procedure.execute(null); }); }