X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fsupport%2FWriteRequestScheduleSupport.java;h=c44c2b91dd590c4aa18d6e24b13f2a5643b1bddd;hb=236aa4e765e0acd6e31cbc42dd9df9c2c23677e2;hp=c4c1ced1cf1f7ada32d02bbc26c88691381283cd;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/support/WriteRequestScheduleSupport.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/support/WriteRequestScheduleSupport.java index c4c1ced1c..c44c2b91d 100644 --- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/support/WriteRequestScheduleSupport.java +++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/support/WriteRequestScheduleSupport.java @@ -1,33 +1,33 @@ -package org.simantics.db.impl.support; - -import java.util.concurrent.Semaphore; - -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; -import org.simantics.utils.datastructures.Callback; - -/** - * @author Tuukka Lehtonen - */ -public interface WriteRequestScheduleSupport { - - void scheduleRequest(DelayedWrite request, Callback callback, Semaphore notify, - Boolean combine); - - void scheduleRequest(DelayedWriteResult request, Procedure procedure, Semaphore notify, Boolean combine); - - void scheduleRequest(Write request, Callback callback, Semaphore notify, Boolean combine); - - void scheduleRequest(WriteOnly request, Callback callback, Semaphore notify, Boolean combine); - - void scheduleRequest(WriteOnlyResult request, Procedure callback, Semaphore notify, Boolean combine); - - void scheduleRequest(WriteResult request, Procedure procedure, Semaphore notify, Boolean combine); - +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 { + + void scheduleRequest(DelayedWrite request, Consumer callback, Semaphore notify, + Boolean combine); + + void scheduleRequest(DelayedWriteResult request, Procedure procedure, Semaphore notify, Boolean combine); + + void scheduleRequest(Write request, Consumer callback, Semaphore notify, Boolean combine); + + void scheduleRequest(WriteOnly request, Consumer callback, Semaphore notify, Boolean combine); + + void scheduleRequest(WriteOnlyResult request, Procedure callback, Semaphore notify, Boolean combine); + + void scheduleRequest(WriteResult request, Procedure procedure, Semaphore notify, Boolean combine); + } \ No newline at end of file