Make HgPullCommand synchronous. This fixes IDEA-68096

[idea/community.git] / plugins / hg4idea / src / org / zmlx / hg4idea / command / HgPullCommand.java

diff --git a/plugins/hg4idea/src/org/zmlx/hg4idea/command/HgPullCommand.java b/plugins/hg4idea/src/org/zmlx/hg4idea/command/HgPullCommand.java
index dc7a96cf2c11a8416519763a25607034cb61f671..bf2b1f8f92a946d3216502ebcf24c1c9c574287e 100644 (file)
--- a/plugins/hg4idea/src/org/zmlx/hg4idea/command/HgPullCommand.java
+++ b/plugins/hg4idea/src/org/zmlx/hg4idea/command/HgPullCommand.java
@@ -18,11 +18,9 @@ import com.intellij.openapi.vcs.VcsException;
 import com.intellij.openapi.vfs.VirtualFile;
 import org.apache.commons.lang.StringUtils;
 import org.jetbrains.annotations.NotNull;
-import org.jetbrains.annotations.Nullable;
 import org.zmlx.hg4idea.HgVcs;
 import org.zmlx.hg4idea.execution.HgCommandExecutor;
 import org.zmlx.hg4idea.execution.HgCommandResult;
-import org.zmlx.hg4idea.execution.HgCommandResultHandler;
 import org.zmlx.hg4idea.util.HgErrorUtil;
 import org.zmlx.hg4idea.util.HgUtil;
 
@@ -78,22 +76,18 @@ public class HgPullCommand {
 
     final HgCommandExecutor executor = new HgCommandExecutor(project);
     executor.setShowOutput(true);
-    executor.execute(repo, "pull", arguments, new HgCommandResultHandler() {
-      @Override
-      public void process(@Nullable HgCommandResult result) {
-        if (HgErrorUtil.isAuthorizationError(result)) {
-          HgUtil.notifyError(project, "Authorization required", "http authorization required for <code>" + source + "</code>");
-        } else if (HgErrorUtil.isAbort(result)) {
-          if (result != null) {
-            LOG.error(new VcsException(result.getRawError()));
-          } else {
-            LOG.error("Error handing result of 'hg pull' execution.");
-          }
-        } else {
-          project.getMessageBus().syncPublisher(HgVcs.REMOTE_TOPIC).update(project);
-        }
+    final HgCommandResult result = executor.executeInCurrentThread(repo, "pull", arguments);
+    if (HgErrorUtil.isAuthorizationError(result)) {
+      HgUtil.notifyError(project, "Authorization required", "http authorization required for <code>" + source + "</code>");
+    } else if (HgErrorUtil.isAbort(result)) {
+      if (result != null) {
+        LOG.error(new VcsException(result.getRawError()));
+      } else {
+        LOG.error("Error handing result of 'hg pull' execution.");
       }
-    });
+    } else {
+      project.getMessageBus().syncPublisher(HgVcs.REMOTE_TOPIC).update(project);
+    }
   }
 
 }