Add AnalysisContext.onResultInvalidated(descriptor).

pkg/analyzer/lib/src/context/context.dart

 // Copyright (c) 2015, 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 analyzer.src.context.context;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:analyzer/dart/ast/ast.dart';
@@ skipping 176 matching lines @@
   /**
    * The listeners that are to be notified when various analysis results are
    * produced in this context.
    */
   List<AnalysisListener> _listeners = new List<AnalysisListener>();
 
   @override
   ResultProvider resultProvider;
 
   /**
+   * The map of [InvalidatedResult] controllers.
+   */
+  final Map<ResultDescriptor, StreamController<InvalidatedResult>>
+      _resultInvalidatedControllers =
+      <ResultDescriptor, StreamController<InvalidatedResult>>{};
+
+  /**
    * The most recently incrementally resolved source, or `null` when it was
    * already validated, or the most recent change was not incrementally resolved.
    */
   Source incrementalResolutionValidation_lastUnitSource;
 
   /**
    * The most recently incrementally resolved library source, or `null` when it
    * was already validated, or the most recent change was not incrementally
    * resolved.
    */
@@ skipping 468 matching lines @@
    * Create an analysis cache based on the given source [factory].
    */
   AnalysisCache createCacheFromSourceFactory(SourceFactory factory) {
     if (factory == null) {
       return new AnalysisCache(<CachePartition>[_privatePartition]);
     }
     DartSdk sdk = factory.dartSdk;
     if (sdk == null) {
       return new AnalysisCache(<CachePartition>[_privatePartition]);
     }
-    return new AnalysisCache(<CachePartition>[
+    AnalysisCache cache = new AnalysisCache(<CachePartition>[
       AnalysisEngine.instance.partitionManager.forSdk(sdk),
       _privatePartition
     ]);
+    cache.onResultInvalidated.listen((InvalidatedResult event) {
+      _resultInvalidatedControllers[event.descriptor]?.add(event);
+    });
+    return cache;
   }
 
   /**
    * Create a minimalistic mock dart:async library
    * to stand in for a real one if one does not exist
    * facilitating creation a type provider without dart:async.
    */
   LibraryElement createMockAsyncLib(LibraryElement coreLibrary) {
     InterfaceType objType = coreLibrary.getType('Object').type;
 
@@ skipping 398 matching lines @@
         !_referencesDartHtml(librarySource) &&
         entry.getValue(IS_LAUNCHABLE);
   }
 
   @override
   Stream<ComputedResult> onResultComputed(ResultDescriptor descriptor) {
     return driver.onResultComputed(descriptor);
   }
 
   @override
+  Stream<InvalidatedResult> onResultInvalidated(ResultDescriptor descriptor) {
+    return _resultInvalidatedControllers.putIfAbsent(descriptor, () {
+      return new StreamController<InvalidatedResult>.broadcast(sync: true);
+    }).stream;
+  }
+
+  @override
   CompilationUnit parseCompilationUnit(Source source) {
     if (!AnalysisEngine.isDartFileName(source.shortName)) {
       return null;
     }
     try {
       getContents(source);
     } catch (exception, stackTrace) {
       throw new AnalysisException('Could not get contents of $source',
           new CaughtException(exception, stackTrace));
     }
@@ skipping 1029 matching lines @@
     }
     DartSdk sdk = factory.dartSdk;
     if (sdk == null) {
       throw new IllegalArgumentException(
           "The source factory for an SDK analysis context must have a DartUriResolver");
     }
     return new AnalysisCache(
         <CachePartition>[AnalysisEngine.instance.partitionManager.forSdk(sdk)]);
   }
 }