Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1589)

Unified Diff: pkg/watcher/lib/src/directory_watcher/resubscribable.dart

Issue 812253002: Delete a bunch of packages that are now on GitHub. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Un-delete http Created 6 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: pkg/watcher/lib/src/directory_watcher/resubscribable.dart
diff --git a/pkg/watcher/lib/src/directory_watcher/resubscribable.dart b/pkg/watcher/lib/src/directory_watcher/resubscribable.dart
deleted file mode 100644
index 7d99fc05be33e4d8472384062723bfce911aa7c7..0000000000000000000000000000000000000000
--- a/pkg/watcher/lib/src/directory_watcher/resubscribable.dart
+++ /dev/null
@@ -1,77 +0,0 @@
-// Copyright (c) 2013, 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 watcher.directory_watcher.resubscribable;
-
-import 'dart:async';
-
-import '../directory_watcher.dart';
-import '../watch_event.dart';
-
-typedef ManuallyClosedDirectoryWatcher WatcherFactory();
-
-/// A wrapper for [ManuallyClosedDirectoryWatcher] that encapsulates support for
-/// closing the watcher when it has no subscribers and re-opening it when it's
-/// re-subscribed.
-///
-/// It's simpler to implement watchers without worrying about this behavior.
-/// This class wraps a watcher class which can be written with the simplifying
-/// assumption that it can continue emitting events until an explicit `close`
-/// method is called, at which point it will cease emitting events entirely. The
-/// [ManuallyClosedDirectoryWatcher] interface is used for these watchers.
-///
-/// This would be more cleanly implemented as a function that takes a class and
-/// emits a new class, but Dart doesn't support that sort of thing. Instead it
-/// takes a factory function that produces instances of the inner class.
-abstract class ResubscribableDirectoryWatcher implements DirectoryWatcher {
- /// The factory function that produces instances of the inner class.
- final WatcherFactory _factory;
-
- final String directory;
-
- Stream<WatchEvent> get events => _eventsController.stream;
- StreamController<WatchEvent> _eventsController;
-
- bool get isReady => _readyCompleter.isCompleted;
-
- Future get ready => _readyCompleter.future;
- var _readyCompleter = new Completer();
-
- /// Creates a new [ResubscribableDirectoryWatcher] wrapping the watchers
- /// emitted by [_factory].
- ResubscribableDirectoryWatcher(this.directory, this._factory) {
- var watcher;
- var subscription;
-
- _eventsController = new StreamController<WatchEvent>.broadcast(
- onListen: () {
- watcher = _factory();
- subscription = watcher.events.listen(_eventsController.add,
- onError: _eventsController.addError,
- onDone: _eventsController.close);
-
- // It's important that we complete the value of [_readyCompleter] at the
- // time [onListen] is called, as opposed to the value when [watcher.ready]
- // fires. A new completer may be created by that time.
- watcher.ready.then(_readyCompleter.complete);
- }, onCancel: () {
- // Cancel the subscription before closing the watcher so that the
- // watcher's `onDone` event doesn't close [events].
- subscription.cancel();
- watcher.close();
- _readyCompleter = new Completer();
- }, sync: true);
- }
-}
-
-/// An interface for watchers with an explicit, manual [close] method.
-///
-/// See [ResubscribableDirectoryWatcher].
-abstract class ManuallyClosedDirectoryWatcher implements DirectoryWatcher {
- /// Closes the watcher.
- ///
- /// Subclasses should close their [events] stream and release any internal
- /// resources.
- void close();
-}
« no previous file with comments | « pkg/watcher/lib/src/directory_watcher/polling.dart ('k') | pkg/watcher/lib/src/directory_watcher/windows.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698