-package org.simantics.db.impl.support;\r
-\r
-import java.util.concurrent.Semaphore;\r
-\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.db.procedure.Procedure;\r
-import org.simantics.db.request.DelayedWrite;\r
-import org.simantics.db.request.DelayedWriteResult;\r
-import org.simantics.db.request.Write;\r
-import org.simantics.db.request.WriteOnly;\r
-import org.simantics.db.request.WriteOnlyResult;\r
-import org.simantics.db.request.WriteResult;\r
-import org.simantics.utils.datastructures.Callback;\r
-\r
-/**\r
- * @author Tuukka Lehtonen\r
- */\r
-public interface WriteRequestScheduleSupport {\r
-\r
- <T> void scheduleRequest(DelayedWrite request, Callback<DatabaseException> callback, Semaphore notify,\r
- Boolean combine);\r
-\r
- <T> void scheduleRequest(DelayedWriteResult<T> request, Procedure<T> procedure, Semaphore notify, Boolean combine);\r
-\r
- <T> void scheduleRequest(Write request, Callback<DatabaseException> callback, Semaphore notify, Boolean combine);\r
-\r
- <T> void scheduleRequest(WriteOnly request, Callback<DatabaseException> callback, Semaphore notify, Boolean combine);\r
-\r
- <T> void scheduleRequest(WriteOnlyResult<T> request, Procedure<T> callback, Semaphore notify, Boolean combine);\r
-\r
- <T> void scheduleRequest(WriteResult<T> request, Procedure<T> procedure, Semaphore notify, Boolean combine);\r
-\r
+package org.simantics.db.impl.support;
+
+import java.util.concurrent.Semaphore;
+import java.util.function.Consumer;
+
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.procedure.Procedure;
+import org.simantics.db.request.DelayedWrite;
+import org.simantics.db.request.DelayedWriteResult;
+import org.simantics.db.request.Write;
+import org.simantics.db.request.WriteOnly;
+import org.simantics.db.request.WriteOnlyResult;
+import org.simantics.db.request.WriteResult;
+
+/**
+ * @author Tuukka Lehtonen
+ */
+public interface WriteRequestScheduleSupport {
+
+ <T> void scheduleRequest(DelayedWrite request, Consumer<DatabaseException> callback, Semaphore notify,
+ Boolean combine);
+
+ <T> void scheduleRequest(DelayedWriteResult<T> request, Procedure<T> procedure, Semaphore notify, Boolean combine);
+
+ <T> void scheduleRequest(Write request, Consumer<DatabaseException> callback, Semaphore notify, Boolean combine);
+
+ <T> void scheduleRequest(WriteOnly request, Consumer<DatabaseException> callback, Semaphore notify, Boolean combine);
+
+ <T> void scheduleRequest(WriteOnlyResult<T> request, Procedure<T> callback, Semaphore notify, Boolean combine);
+
+ <T> void scheduleRequest(WriteResult<T> request, Procedure<T> procedure, Semaphore notify, Boolean combine);
+