Remove support for watching changes to the set of files known to a driver

pkg/analyzer/lib/src/dart/analysis/file_state.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:convert';
 import 'dart:typed_data';
 
 import 'package:analyzer/dart/ast/ast.dart';
 import 'package:analyzer/dart/ast/token.dart';
 import 'package:analyzer/error/listener.dart';
 import 'package:analyzer/file_system/file_system.dart';
 import 'package:analyzer/src/dart/analysis/defined_names.dart';
 import 'package:analyzer/src/dart/analysis/referenced_names.dart';
 import 'package:analyzer/src/dart/analysis/top_level_declaration.dart';
@@ skipping 664 matching lines @@
    * Mapping from a URI to the corresponding [FileState].
    */
   final Map<Uri, FileState> _uriToFile = {};
 
   /**
    * All known file paths.
    */
   final Set<String> knownFilePaths = new Set<String>();
 
   /**
-   * The paths of files that were added to the set of known files since the
-   * last [knownFilesSetChanges] notification.
-   */
-  final Set<String> _addedKnownFiles = new Set<String>();
-
-  /**
-   * If not `null`, this delay will be awaited instead of the default one.
-   */
-  Duration _knownFilesSetChangesDelay;
-
-  /**
-   * The instance of timer that is scheduled to send a new update to the
-   * [knownFilesSetChanges] stream, or `null` if there are no changes to the
-   * set of known files to notify the stream about.
-   */
-  Timer _knownFilesSetChangesTimer;
-
-  /**
-   * Whether the [knownFilesSetChanges] stream is requested.
-   */
-  bool _knownFilesSetChangesRequested = false;
-
-  /**
-   * The controller for the [knownFilesSetChanges] stream.
-   */
-  final StreamController<KnownFilesSetChange> _knownFilesSetChangesController =
-      new StreamController<KnownFilesSetChange>();
-
-  /**
    * Mapping from a path to the flag whether there is a URI for the path.
    */
   final Map<String, bool> _hasUriForPath = {};
 
   /**
    * Mapping from a path to the corresponding [FileState]s, canonical or not.
    */
   final Map<String, List<FileState>> _pathToFiles = {};
 
   /**
@@ skipping 24 matching lines @@
       {this.externalSummaries}) {
     _testView = new FileSystemStateTestView(this);
   }
 
   /**
    * Return the known files.
    */
   List<FileState> get knownFiles =>
       _pathToFiles.values.map((files) => files.first).toList();
 
-  /**
-   * Return the [Stream] that is periodically notified about changes to the
-   * known files set.
-   */
-  Stream<KnownFilesSetChange> get knownFilesSetChanges {
-    // If this is the first (and actually the only) time when the stream is
-    // requested, schedule the timer to send updates.
-    if (!_knownFilesSetChangesRequested) {
-      _knownFilesSetChangesRequested = true;
-      _scheduleKnownFilesSetChange();
-    }
-    return _knownFilesSetChangesController.stream;
-  }
-
   @visibleForTesting
   FileSystemStateTestView get test => _testView;
 
   /**
    * Return the [FileState] instance that correspond to an unresolved URI.
    */
   FileState get unresolvedFile {
     if (_unresolvedFile == null) {
       _unresolvedFile = new FileState._(this, null, null, null);
       _unresolvedFile.refresh();
@@ skipping 116 matching lines @@
     _pathToCanonicalFile.clear();
     _partToLibraries.clear();
   }
 
   void _addFileWithPath(String path, FileState file) {
     var files = _pathToFiles[path];
     if (files == null) {
       knownFilePaths.add(path);
       files = <FileState>[];
       _pathToFiles[path] = files;
-      // Schedule the stream update.
-      _addedKnownFiles.add(path);
-      _scheduleKnownFilesSetChange();
     }
     files.add(file);
   }
-
-  void _scheduleKnownFilesSetChange() {
-    // Schedule the timer only if there is a client who listens the stream.
-    if (!_knownFilesSetChangesRequested) {
-      return;
-    }
-
-    Duration delay = _knownFilesSetChangesDelay ?? new Duration(seconds: 1);
-    _knownFilesSetChangesTimer ??= new Timer(delay, () {
-      Set<String> addedFiles = _addedKnownFiles.toSet();
-      Set<String> removedFiles = new Set<String>();
-      _knownFilesSetChangesController
-          .add(new KnownFilesSetChange(addedFiles, removedFiles));
-      _addedKnownFiles.clear();
-      _knownFilesSetChangesTimer = null;
-    });
-  }
 }
 
 @visibleForTesting
 class FileSystemStateTestView {
   final FileSystemState state;
 
   FileSystemStateTestView(this.state);
 
   Set<FileState> get filesWithoutTransitiveFiles {
     return state._uriToFile.values
         .where((f) => f._transitiveFiles == null)
         .toSet();
   }
 
   Set<FileState> get filesWithoutTransitiveSignature {
     return state._uriToFile.values
         .where((f) => f._transitiveSignature == null)
         .toSet();
   }
-
-  void set knownFilesDelay(Duration value) {
-    state._knownFilesSetChangesDelay = value;
-  }
 }
-
-/**
- * Information about changes to the known file set.
- */
-class KnownFilesSetChange {
-  final Set<String> added;
-  final Set<String> removed;
-
-  KnownFilesSetChange(this.added, this.removed);
-}