Index: pkg/watcher/test/no_subscription_test.dart |
diff --git a/pkg/watcher/test/no_subscription_test.dart b/pkg/watcher/test/no_subscription_test.dart |
deleted file mode 100644 |
index 2e7b6d3ffe44cafb9ae1ecc93630c3abf7e6ec52..0000000000000000000000000000000000000000 |
--- a/pkg/watcher/test/no_subscription_test.dart |
+++ /dev/null |
@@ -1,75 +0,0 @@ |
-// Copyright (c) 2012, 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:scheduled_test/scheduled_test.dart'; |
-import 'package:watcher/watcher.dart'; |
- |
-import 'utils.dart'; |
- |
-main() { |
- initConfig(); |
- |
- setUp(createSandbox); |
- |
- test('does not notify for changes when there were no subscribers', () { |
- // Note that this test doesn't rely as heavily on the test functions in |
- // utils.dart because it needs to be very explicit about when the event |
- // stream is and is not subscribed. |
- var watcher = createWatcher(); |
- |
- // Subscribe to the events. |
- var completer = new Completer(); |
- var subscription = watcher.events.listen(wrapAsync((event) { |
- expect(event.type, equals(ChangeType.ADD)); |
- expect(event.path, endsWith("file.txt")); |
- completer.complete(); |
- })); |
- |
- writeFile("file.txt"); |
- |
- // Then wait until we get an event for it. |
- schedule(() => completer.future); |
- |
- // Unsubscribe. |
- schedule(() { |
- subscription.cancel(); |
- }); |
- |
- // Now write a file while we aren't listening. |
- writeFile("unwatched.txt"); |
- |
- // Then start listening again. |
- schedule(() { |
- completer = new Completer(); |
- subscription = watcher.events.listen(wrapAsync((event) { |
- // We should get an event for the third file, not the one added while |
- // we weren't subscribed. |
- expect(event.type, equals(ChangeType.ADD)); |
- expect(event.path, endsWith("added.txt")); |
- completer.complete(); |
- })); |
- }); |
- |
- // The watcher will have been cancelled and then resumed in the middle of |
- // its pause between polling loops. That means the second scan to skip |
- // what changed while we were unsubscribed won't happen until after that |
- // delay is done. Wait long enough for that to happen. |
- // |
- // We're doing * 4 here because that seems to give the slower bots enough |
- // time for this to complete. |
- schedule(() => new Future.delayed(watcher.pollingDelay * 4)); |
- |
- // And add a third file. |
- writeFile("added.txt"); |
- |
- // Wait until we get an event for the third file. |
- schedule(() => completer.future); |
- |
- schedule(() { |
- subscription.cancel(); |
- }); |
- }); |
-} |