Add a ScheduledProcess class to pkg/scheduled_test.

pkg/scheduled_test/test/value_future_test.dart

Index: pkg/scheduled_test/test/value_future_test.dart
diff --git a/pkg/scheduled_test/test/value_future_test.dart b/pkg/scheduled_test/test/value_future_test.dart
new file mode 100644
index 0000000000000000000000000000000000000000..a5777b31188153ea1f27c430449844ed44f3fc13
--- /dev/null
+++ b/pkg/scheduled_test/test/value_future_test.dart
@@ -0,0 +1,127 @@
+// 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 value_future_test;
+
+import 'dart:async';
+
+import 'package:scheduled_test/src/value_future.dart';
+import 'package:unittest/unittest.dart';
+
+void main() {
+  group('works like a normal Future for', () {
+    var completer;
+    var future;
+
+    setUp(() {
+      completer = new Completer();
+      future = new ValueFuture(completer.future);
+    });
+
+    test('.asStream on success', () {
+      expect(future.asStream().toList(), completion(equals(['success'])));
+      completer.complete('success');
+    });
+
+    test('.asStream on error', () {
+      expect(future.asStream().toList(), throwsA(equals('error')));
+      completer.completeError('error');
+    });
+
+    test('.then and .catchError on success', () {
+      expect(future.then((v) => "transformed $v")
+              .catchError((e) => "caught ${e.error}"),
+          completion(equals('transformed success')));
+      completer.complete('success');
+    });
+
+    test('.then and .catchError on error', () {
+      expect(future.then((v) => "transformed $v")
+              .catchError((e) => "caught ${e.error}"),
+          completion(equals('caught error')));
+      completer.completeError('error');
+    });
+
+    test('.then with onError on success', () {
+      expect(future.then((v) => "transformed $v",
+              onError: (e) => "caught ${e.error}"),
+          completion(equals('transformed success')));
+      completer.complete('success');
+    });
+
+    test('.then with onError on error', () {
+      expect(future.then((v) => "transformed $v",
+              onError: (e) => "caught ${e.error}"),
+          completion(equals('caught error')));
+      completer.completeError('error');
+    });
+
+    test('.whenComplete on success', () {
+      expect(future.whenComplete(() {
+        throw 'whenComplete';
+      }), throwsA(equals('whenComplete')));
+      completer.complete('success');
+    });
+
+    test('.whenComplete on error', () {
+      expect(future.whenComplete(() {
+        throw 'whenComplete';
+      }), throwsA(equals('whenComplete')));
+      completer.completeError('error');
+    });
+  });
+
+  group('before completion', () {
+    var future;
+
+    setUp(() {
+      future = new ValueFuture(new Completer().future);
+    });
+
+    test('.value is null', () {
+      expect(future.value, isNull);
+    });
+
+    test('.hasValue is false', () {
+      expect(future.hasValue, isFalse);
+    });
+  });
+
+  group('after successful completion', () {
+    var future;
+
+    setUp(() {
+      var completer = new Completer();
+      future = new ValueFuture(completer.future);
+      completer.complete(12);
+    });
+
+    test('.value is the result of the future', () {
+      expect(future.value, equals(12));
+    });
+
+    test('.hasValue is true', () {
+      expect(future.hasValue, isTrue);
+    });
+  });
+
+  group('after an error completion', () {
+    var future;
+
+    setUp(() {
+      var completer = new Completer();
+      future = new ValueFuture(completer.future);
+      future.catchError((e) {});
+      completer.completeError('bad');
+    });
+
+    test('.value is null', () {
+      expect(future.value, isNull);
+    });
+
+    test('.hasValue is false', () {
+      expect(future.hasValue, isFalse);
+    });
+  });
+}