anchor.diff:    /**
      * The [StreamController] reporting [InvalidatedResult]s.
      */
  -  final StreamController<InvalidatedResult> _onResultInvalidated =
  -      new StreamController<InvalidatedResult>.broadcast(sync: true);
  +  final ReentrantSynchronousStream<InvalidatedResult> onResultInvalidated =
  +      new ReentrantSynchronousStream<InvalidatedResult>();
   
     /**
      * A table mapping the targets belonging to this partition to the information
  
positive.code:   /**
     * The [StreamController] reporting [InvalidatedResult]s.
     */
    final StreamController<InvalidatedResult> _onResultInvalidated =
        new StreamController<InvalidatedResult>.broadcast(sync: true);
  
    /**
     * Initialize a newly created cache to have the given [partitions]. The
  
negative.code:   AnalysisCache(this._partitions) {
      for (CachePartition partition in _partitions) {
        partition.onResultInvalidated.listen((InvalidatedResult event) {
          onResultInvalidated.add(event);
        });
      }
    }
  
    // TODO(brianwilkerson) Implement or delete this.
  //  /**
  