From 5cadb8839c982d28d7f09fce599ebda304438ff2 Mon Sep 17 00:00:00 2001
From: Julia Beliaeva <Julia.Beliaeva@jetbrains.com>
Date: Wed, 4 Jul 2018 23:09:56 +0300
Subject: [PATCH] [file-history] extract RefreshRequest class

---
 .../vcs/history/FileHistoryRefresher.java     | 65 +++++++++++--------
 1 file changed, 39 insertions(+), 26 deletions(-)

diff --git a/platform/vcs-impl/src/com/intellij/openapi/vcs/history/FileHistoryRefresher.java b/platform/vcs-impl/src/com/intellij/openapi/vcs/history/FileHistoryRefresher.java
index 3593dae81d8c..3c9654e41a62 100644
--- a/platform/vcs-impl/src/com/intellij/openapi/vcs/history/FileHistoryRefresher.java
+++ b/platform/vcs-impl/src/com/intellij/openapi/vcs/history/FileHistoryRefresher.java
@@ -15,6 +15,7 @@
  */
 package com.intellij.openapi.vcs.history;
 
+import com.intellij.openapi.Disposable;
 import com.intellij.openapi.application.ApplicationManager;
 import com.intellij.openapi.vcs.AbstractVcs;
 import com.intellij.openapi.vcs.FilePath;
@@ -66,32 +67,8 @@ public class FileHistoryRefresher implements FileHistoryRefresherI {
     myStartingRevisionNumber = startingRevisionNumber;
     mySessionPartner = new FileHistorySessionPartner(vcsHistoryProvider, path, startingRevisionNumber, vcs, this);
 
-    int delayMillis = 20_000;
-    Alarm updateAlarm = new Alarm(Alarm.ThreadToUse.SWING_THREAD, mySessionPartner);
-    updateAlarm.addRequest(new Runnable() {
-      Future<?> lastTask;
-
-      public void run() {
-        if (lastTask != null) {
-          lastTask.cancel(false);
-        }
-        if (myVcs.getProject().isDisposed()) {
-          return;
-        }
-
-        updateAlarm.cancelAllRequests();
-        if (updateAlarm.isDisposed()) return;
-        updateAlarm.addRequest(this, delayMillis);
-
-        if (!ApplicationManager.getApplication().isActive()) return;
-
-        lastTask = ourExecutor.submit(() -> {
-          if (!updateAlarm.isDisposed() && mySessionPartner.shouldBeRefreshed()) {
-            ApplicationManager.getApplication().invokeLater(() -> refresh(true));
-          }
-        });
-      }
-    }, delayMillis);
+    RefreshRequest request = new RefreshRequest(20_000, mySessionPartner);
+    request.schedule();
   }
 
   @NotNull
@@ -146,4 +123,40 @@ public class FileHistoryRefresher implements FileHistoryRefresherI {
 
     myFirstTime = false;
   }
+
+  private class RefreshRequest implements Runnable {
+    @NotNull private final Alarm myUpdateAlarm;
+    private final int myDelayMillis;
+    @Nullable Future<?> myLastTask;
+
+    public RefreshRequest(int delayMillis, @NotNull Disposable parent) {
+      myUpdateAlarm = new Alarm(Alarm.ThreadToUse.SWING_THREAD, parent);
+      myDelayMillis = delayMillis;
+    }
+
+    public void run() {
+      if (myLastTask != null) {
+        myLastTask.cancel(false);
+      }
+      if (myVcs.getProject().isDisposed()) {
+        return;
+      }
+
+      myUpdateAlarm.cancelAllRequests();
+      if (myUpdateAlarm.isDisposed()) return;
+      schedule();
+
+      if (!ApplicationManager.getApplication().isActive()) return;
+
+      myLastTask = ourExecutor.submit(() -> {
+        if (!myUpdateAlarm.isDisposed() && mySessionPartner.shouldBeRefreshed()) {
+          ApplicationManager.getApplication().invokeLater(() -> refresh(true));
+        }
+      });
+    }
+
+    public void schedule() {
+      myUpdateAlarm.addRequest(this, myDelayMillis);
+    }
+  }
 }