import java.util.Deque;
import org.simantics.db.RequestProcessor;
+import org.simantics.db.VirtualGraph;
import org.simantics.diagram.internal.DebugPolicy;
import org.simantics.diagram.synchronization.ErrorHandler;
import org.simantics.diagram.synchronization.IModification;
private final RequestProcessor writebackProcessor;
private final ErrorHandler errorHandler;
private final Deque<IModification> writebackQueue = new ArrayDeque<IModification>();
-
+ private final VirtualGraph virtualGraph;
+
public ModificationQueue(RequestProcessor writebackProcessor, ErrorHandler errorHandler) {
this.writebackProcessor = writebackProcessor;
this.errorHandler = errorHandler;
+ this.virtualGraph = null;
+ }
+
+ public ModificationQueue(RequestProcessor writebackProcessor, ErrorHandler errorHandler, VirtualGraph virtualGraph) {
+ this.writebackProcessor = writebackProcessor;
+ this.errorHandler = errorHandler;
+ this.virtualGraph = virtualGraph;
}
public void dispose() {
}
+
ModificationProcessRequest createModificationRequest() {
IModification[] mods = IModification.NONE;
mods = writebackQueue.toArray(IModification.NONE);
writebackQueue.clear();
}
- return new ModificationProcessRequest(errorHandler, mods);
+ return new ModificationProcessRequest(errorHandler, mods, virtualGraph);
}
void dispatchModifications() {