Index: pkg/scheduled_test/test/descriptor/async_test.dart |
diff --git a/pkg/scheduled_test/test/descriptor/async_test.dart b/pkg/scheduled_test/test/descriptor/async_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..b35718fa15dac27dfe947e0aeb985d8e02b6f1df |
--- /dev/null |
+++ b/pkg/scheduled_test/test/descriptor/async_test.dart |
@@ -0,0 +1,143 @@ |
+// 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. |
+ |
+import 'dart:async'; |
+import 'dart:io'; |
+ |
+import 'package:pathos/path.dart' as path; |
+import 'package:scheduled_test/descriptor.dart' as d; |
+import 'package:scheduled_test/scheduled_test.dart'; |
+ |
+import '../metatest.dart'; |
+import 'utils.dart'; |
+ |
+void main() { |
+ setUpTimeout(); |
+ |
+ expectTestsPass("async().create() forwards to file().create", () { |
+ test('test', () { |
+ scheduleSandbox(); |
+ |
+ d.async(pumpEventQueue().then((_) { |
+ return d.file('name.txt', 'contents'); |
+ })).create(); |
+ |
+ d.file('name.txt', 'contents').validate(); |
+ }); |
+ }); |
+ |
+ expectTestsPass("async().create() forwards to directory().create", () { |
+ test('test', () { |
+ scheduleSandbox(); |
+ |
+ d.async(pumpEventQueue().then((_) { |
+ return d.dir('dir', [ |
+ d.file('file1.txt', 'contents1'), |
+ d.file('file2.txt', 'contents2') |
+ ]); |
+ })).create(); |
+ |
+ d.dir('dir', [ |
+ d.file('file1.txt', 'contents1'), |
+ d.file('file2.txt', 'contents2') |
+ ]).validate(); |
+ }); |
+ }); |
+ |
+ expectTestsPass("async().validate() forwards to file().validate", () { |
+ test('test', () { |
+ scheduleSandbox(); |
+ |
+ d.file('name.txt', 'contents').create(); |
+ |
+ d.async(pumpEventQueue().then((_) { |
+ return d.file('name.txt', 'contents'); |
+ })).validate(); |
+ }); |
+ }); |
+ |
+ expectTestsPass("async().validate() fails if file().validate fails", () { |
+ var errors; |
+ test('test 1', () { |
+ scheduleSandbox(); |
+ |
+ currentSchedule.onException.schedule(() { |
+ errors = currentSchedule.errors; |
+ }); |
+ |
+ d.async(pumpEventQueue().then((_) { |
+ return d.file('name.txt', 'contents'); |
+ })).validate(); |
+ }); |
+ |
+ test('test 2', () { |
+ expect(errors, everyElement(new isInstanceOf<ScheduleError>())); |
+ expect(errors.length, equals(1)); |
+ expect(errors.first.error, |
+ matches(r"^File not found: '[^']+[\\/]name\.txt'\.$")); |
+ }); |
+ }, passing: ['test 2']); |
+ |
+ expectTestsPass("async().validate() forwards to directory().validate", () { |
+ test('test', () { |
+ scheduleSandbox(); |
+ |
+ d.dir('dir', [ |
+ d.file('file1.txt', 'contents1'), |
+ d.file('file2.txt', 'contents2') |
+ ]).create(); |
+ |
+ d.async(pumpEventQueue().then((_) { |
+ return d.dir('dir', [ |
+ d.file('file1.txt', 'contents1'), |
+ d.file('file2.txt', 'contents2') |
+ ]); |
+ })).validate(); |
+ }); |
+ }); |
+ |
+ expectTestsPass("async().create() fails if directory().create fails", () { |
+ var errors; |
+ test('test 1', () { |
+ scheduleSandbox(); |
+ |
+ currentSchedule.onException.schedule(() { |
+ errors = currentSchedule.errors; |
+ }); |
+ |
+ d.async(pumpEventQueue().then((_) { |
+ return d.dir('dir', [ |
+ d.file('file1.txt', 'contents1'), |
+ d.file('file2.txt', 'contents2') |
+ ]); |
+ })).validate(); |
+ }); |
+ |
+ test('test 2', () { |
+ expect(errors, everyElement(new isInstanceOf<ScheduleError>())); |
+ expect(errors.length, equals(1)); |
+ expect(errors.first.error, |
+ matches(r"^Directory not found: '[^']+[\\/]dir'\.$")); |
+ }); |
+ }, passing: ['test 2']); |
+ |
+ expectTestsPass("async().load() fails", () { |
+ test('test', () { |
+ scheduleSandbox(); |
+ |
+ expect(d.async(new Future.immediate(d.file('name.txt'))) |
+ .load('path').toList(), |
+ throwsA(equals("AsyncDescriptors don't support load()."))); |
+ }); |
+ }); |
+ |
+ expectTestsPass("async().read() fails", () { |
+ test('test', () { |
+ scheduleSandbox(); |
+ |
+ expect(d.async(new Future.immediate(d.file('name.txt'))).read().toList(), |
+ throwsA(equals("AsyncDescriptors don't support read()."))); |
+ }); |
+ }); |
+} |