build_test/lib/src/fake_watcher.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 'package:watcher/watcher.dart';

/// A fake [DirectoryWatcher].
///
/// Use the static [notifyWatchers] method to add simulated events.
class FakeWatcher implements DirectoryWatcher {
  @override
  String get directory => path;

  @override
  final String path;

  FakeWatcher(this.path) {
    watchers.add(this);
  }

  final _eventsController = StreamController<WatchEvent>();

  @override
  Stream<WatchEvent> get events => _eventsController.stream;

  @override
  Future get ready => Future(() {});

  @override
  bool get isReady => true;

  /// All watchers.
  static final List<FakeWatcher> watchers = <FakeWatcher>[];

  /// Notify all active watchers of [event] if their [FakeWatcher#path] matches.
  /// The path will also be adjusted to remove the path.
  static void notifyWatchers(WatchEvent event) {
    for (var watcher in watchers) {
      if (event.path.startsWith(watcher.path)) {
        watcher._eventsController.add(WatchEvent(event.type, event.path));
      }
    }
  }
}