Send analysis notifications after subscription.

pkg/analyzer/lib/src/dart/analysis/driver.dart

 // Copyright (c) 2016, 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.
 
 import 'dart:async';
 import 'dart:collection';
 import 'dart:convert';
 
 import 'package:analyzer/dart/ast/ast.dart';
 import 'package:analyzer/dart/ast/token.dart';
@@ skipping 359 matching lines @@
     var completer = new Completer<AnalysisResult>();
     _requestedFiles
         .putIfAbsent(path, () => <Completer<AnalysisResult>>[])
         .add(completer);
     _transitionToAnalyzing();
     _hasWork.notify();
     return completer.future;
   }
 
   /**
+   * Return `true` if the file with the given [path] was explicitly added
+   * to analysis using [addFile].
+   */
+  bool isAddedFile(String path) {
+    return _explicitFiles.contains(path);
+  }
+
+  /**
    * Returns a [Future] that completes after pumping the event queue [times]
    * times. By default, this should pump the event queue enough times to allow
    * any code to run, as long as it's not waiting on some external event.
    */
   Future pumpEventQueue([int times = 5000]) {
     if (times == 0) return new Future.value();
     // We use a delayed future to allow microtask events to finish. The
     // Future.value or Future() constructors use scheduleMicrotask themselves and
     // would therefore not wait for microtask callbacks that are scheduled after
     // invoking this method.
@@ skipping 832 matching lines @@
       }
     }
     for (UnlinkedExportPublic export in unit.publicNamespace.exports) {
       referenced.exported.add(export.uri);
     }
     return referenced;
   }
 
   _ReferencedUris._();
 }