Issue 28300. Reset refactoring when analysis started with the new analysis driver.

pkg/analysis_server/lib/src/analysis_server.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library analysis.server;
 
 import 'dart:async';
 import 'dart:collection';
 import 'dart:core';
 import 'dart:io' as io;
@@ skipping 224 matching lines @@
   Completer _onAnalysisCompleteCompleter;
 
   /**
    * The [Completer] that completes when the next operation is performed.
    */
   Completer _test_onOperationPerformedCompleter;
 
   /**
    * The controller that is notified when analysis is started.
    */
-  StreamController<AnalysisContext> _onAnalysisStartedController;
+  StreamController<bool> _onAnalysisStartedController;
 
   /**
    * The controller that is notified when a single file has been analyzed.
    */
   StreamController<ChangeNotice> _onFileAnalyzedController;
 
   /**
    * The controller used to notify others when priority sources change.
    */
   StreamController<PriorityChangeEvent> _onPriorityChangeController;
@@ skipping 229 matching lines @@
     if (isAnalysisComplete()) {
       return new Future.value();
     }
     if (_onAnalysisCompleteCompleter == null) {
       _onAnalysisCompleteCompleter = new Completer();
     }
     return _onAnalysisCompleteCompleter.future;
   }
 
   /**
-   * The stream that is notified when analysis of a context is started.
+   * The stream that is notified with `true` when analysis is started.
    */
-  Stream<AnalysisContext> get onAnalysisStarted {
+  Stream<bool> get onAnalysisStarted {
     return _onAnalysisStartedController.stream;
   }
 
   /**
    * The stream that is notified when contexts are added or removed.
    */
   Stream<ContextsChangedEvent> get onContextsChanged =>
       _onContextsChangedController.stream;
 
   /**
@@ skipping 569 matching lines @@
    */
   void scheduleOperation(ServerOperation operation) {
     addOperation(operation);
     _schedulePerformOperation();
   }
 
   /**
    * Schedules analysis of the given context.
    */
   void schedulePerformAnalysisOperation(AnalysisContext context) {
-    _onAnalysisStartedController.add(context);
+    _onAnalysisStartedController.add(true);
     scheduleOperation(new PerformAnalysisOperation(context, false));
   }
 
   /**
    * This method is called when analysis of the given [AnalysisContext] is
    * done.
    */
   void sendContextAnalysisDoneNotifications(
       AnalysisContext context, AnalysisDoneReason reason) {
     Completer<AnalysisDoneReason> completer =
@@ skipping 63 matching lines @@
     AnalysisStatus analysis = new AnalysisStatus(isAnalyzing);
     channel.sendNotification(
         new ServerStatusParams(analysis: analysis).toNotification());
   }
 
   /**
    * Send status notification to the client. The state of analysis is given by
    * the [status] information.
    */
   void sendStatusNotificationNew(nd.AnalysisStatus status) {
+    if (status.isAnalyzing) {
+      _onAnalysisStartedController.add(true);
+    }
     if (_onAnalysisCompleteCompleter != null && !status.isAnalyzing) {
       _onAnalysisCompleteCompleter.complete();
       _onAnalysisCompleteCompleter = null;
     }
     // Perform on-idle actions.
     if (!status.isAnalyzing) {
       if (generalAnalysisServices
           .contains(GeneralAnalysisService.ANALYZED_FILES)) {
         sendAnalysisNotificationAnalyzedFiles(this);
       }
@@ skipping 939 matching lines @@
   /**
    * The [PerformanceTag] for time spent in server request handlers.
    */
   static PerformanceTag serverRequests = new PerformanceTag('serverRequests');
 
   /**
    * The [PerformanceTag] for time spent in split store microtasks.
    */
   static PerformanceTag splitStore = new PerformanceTag('splitStore');
 }