MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

[vcs-log] inline runInBackground method that is used only once

Browse Source 
Remove catching VcsException since it is not thrown in the code.
This commit is contained in:
Julia Beliaeva
2017-03-24 15:08:12 +03:00
parent 6c5c9dbb03
commit b7ee82ab84
1 changed files with 13 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/vcs-log/impl/src/com/intellij/vcs/log/data/VcsLogData.java
+13 -25
View File
@@ -30,7 +30,6 @@ import com.intellij.openapi.util.registry.Registry;
import com.intellij.openapi.vcs.VcsException;
import com.intellij.openapi.vfs.VirtualFile;
import com.intellij.util.Consumer;
import com.intellij.util.ThrowableConsumer;
import com.intellij.util.containers.ContainerUtil;
import com.intellij.vcs.log.*;
import com.intellij.vcs.log.data.index.VcsLogIndex;
@@ -175,16 +174,21 @@ public class VcsLogData implements Disposable, VcsLogDataProvider {
}
public void initialize() {
final StopWatch initSw = StopWatch.start("initialize");
StopWatch initSw = StopWatch.start("initialize");
myDataLoaderQueue.clear();
runInBackground(indicator -> {
resetState();
readCurrentUser();
DataPack dataPack = myRefresher.readFirstBlock();
fireDataPackChangeEvent(dataPack);
initSw.report();
});
Task.Backgroundable backgroundable = new Task.Backgroundable(myProject, "Loading History...", false) {
@Override
public void run(@NotNull ProgressIndicator indicator) {
indicator.setIndeterminate(true);
resetState();
readCurrentUser();
DataPack dataPack = myRefresher.readFirstBlock();
fireDataPackChangeEvent(dataPack);
initSw.report();
}
};
myDataLoaderQueue.run(backgroundable, null, myRefresher.getProgress().createProgressIndicator());
}
private void readCurrentUser() {
@@ -241,22 +245,6 @@ public class VcsLogData implements Disposable, VcsLogDataProvider {
return myContainingBranchesGetter;
}
private void runInBackground(@NotNull ThrowableConsumer<ProgressIndicator, VcsException> task) {
Task.Backgroundable backgroundable = new Task.Backgroundable(myProject, "Loading History...", false) {
@Override
public void run(@NotNull ProgressIndicator indicator) {
indicator.setIndeterminate(true);
try {
task.consume(indicator);
}
catch (VcsException e) {
throw new RuntimeException(e); // TODO
}
}
};
myDataLoaderQueue.run(backgroundable, null, myRefresher.getProgress().createProgressIndicator());
}
/**
* Refreshes specified roots.
* Does not re-read all log but rather the most recent commits.