Index: packages/async/test/utils.dart |
diff --git a/packages/async/test/utils.dart b/packages/async/test/utils.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..b2ea885adcf34f30f1a422145069d85feafd3578 |
--- /dev/null |
+++ b/packages/async/test/utils.dart |
@@ -0,0 +1,26 @@ |
+// Copyright (c) 2015, 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. |
+ |
+/// Helper utilities for testing. |
+library async.test.util; |
+ |
+import "dart:async"; |
+import "package:test/test.dart"; |
+ |
+/// A zero-millisecond timer should wait until after all microtasks. |
+Future flushMicrotasks() => new Future.delayed(Duration.ZERO); |
+ |
+/// A generic unreachable callback function. |
+/// |
+/// Returns a function that fails the test if it is ever called. |
+unreachable(String name) => ([a, b]) => fail("Unreachable: $name"); |
+ |
+/// A badly behaved stream which throws if it's ever listened to. |
+/// |
+/// Can be used to test cases where a stream should not be used. |
+class UnusableStream extends Stream { |
+ listen(onData, {onError, onDone, cancelOnError}) { |
+ throw new UnimplementedError("Gotcha!"); |
+ } |
+} |