import java.util.Set;
import java.util.UUID;
import java.util.concurrent.Semaphore;
+import java.util.function.Consumer;
import org.simantics.db.AsyncReadGraph;
import org.simantics.db.AsyncRequestProcessor;
import org.simantics.db.request.WriteOnlyResult;
import org.simantics.db.request.WriteResult;
import org.simantics.utils.DataContainer;
-import org.simantics.utils.datastructures.Callback;
import org.simantics.utils.datastructures.Pair;
public class MergingGraphRequestProcessor implements RequestProcessor {
}
@SuppressWarnings("unchecked")
- Callback<Throwable> callback = (Callback<Throwable>)currentRequest.second;
+ Consumer<Throwable> callback = (Consumer<Throwable>)currentRequest.second;
if (currentRequest.first.getClass().equals(SyncWriteRequestAdapter.class)) {
try {
// System.out.println("merg.sync " + adapter);
graph.syncRequest(adapter);
- if(callback != null) callback.run(null);
+ if(callback != null) callback.accept(null);
} catch(Throwable t) {
Logger.defaultLogError(t);
- if(callback != null) callback.run(t);
+ if(callback != null) callback.accept(t);
}
adapter.release();
try {
if(currentRequest.first instanceof Write) graph.syncRequest((Write)currentRequest.first);
else if(currentRequest.first instanceof DelayedWrite) graph.syncRequest((DelayedWrite)currentRequest.first);
- if(callback != null) callback.run(null);
+ if(callback != null) callback.accept(null);
} catch(Throwable t) {
Logger.defaultLogError(t);
- if(callback != null) callback.run(t);
+ if(callback != null) callback.accept(t);
}
}
}
@Override
- public synchronized void asyncRequest(Write request, Callback<DatabaseException> callback) {
+ public synchronized void asyncRequest(Write request, Consumer<DatabaseException> callback) {
// System.out.println(this + " asyncRequest(WriteGraphRequest request)");
}
@Override
- public synchronized void asyncRequest(DelayedWrite request, Callback<DatabaseException> callback) {
+ public synchronized void asyncRequest(DelayedWrite request, Consumer<DatabaseException> callback) {
// System.out.println(this + " asyncRequest(WriteGraphRequest request)");
}
@Override
- public synchronized void asyncRequest(WriteOnly request, Callback<DatabaseException> callback) {
+ public synchronized void asyncRequest(WriteOnly request, Consumer<DatabaseException> callback) {
// System.out.println(this + " asyncRequest(WriteGraphRequest request)");