anchor.diff:    AnalysisCache(this._partitions) {
       for (CachePartition partition in _partitions) {
         partition.onResultInvalidated.listen((InvalidatedResult event) {
  -        _onResultInvalidated.add(event);
  +        onResultInvalidated.add(event);
         });
       }
     }
  -
  -  /**
  -   * Return the stream that is notified when a value is invalidated.
  -   */
  -  Stream<InvalidatedResult> get onResultInvalidated =>
  -      _onResultInvalidated.stream;
   
     // TODO(brianwilkerson) Implement or delete this.
   //  /**
  
positive.code:    * should not be used for any other purpose.
     */
    Map<AnalysisTarget, CacheEntry> get map => _targetMap;
  
    /**
     * Return the stream that is notified when a value is invalidated.
     */
    Stream<InvalidatedResult> get onResultInvalidated =>
        _onResultInvalidated.stream;
  
    /**
     * Notifies the partition that the client is going to stop using it.
  
negative.code:   /**
     * The [StreamController] reporting [InvalidatedResult]s.
     */
    final ReentrantSynchronousStream<InvalidatedResult> onResultInvalidated =
        new ReentrantSynchronousStream<InvalidatedResult>();
  
    /**
     * Initialize a newly created cache to have the given [partitions]. The
  