Index: tests/lib_strong/async/stream_join_test.dart |
diff --git a/tests/lib_strong/async/stream_join_test.dart b/tests/lib_strong/async/stream_join_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..678502cd649694d89ee1f7654fa5e9dee7a5f120 |
--- /dev/null |
+++ b/tests/lib_strong/async/stream_join_test.dart |
@@ -0,0 +1,75 @@ |
+// 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. |
+ |
+// Test the basic StreamController and StreamController.singleSubscription. |
+library stream_join_test; |
+ |
+import 'dart:async'; |
+import 'event_helper.dart'; |
+import 'package:unittest/unittest.dart'; |
+import "package:expect/expect.dart"; |
+ |
+main() { |
+ test("join-empty", () { |
+ StreamController c = new StreamController(); |
+ c.stream.join("X").then(expectAsync( |
+ (String s) => expect(s, equals("")) |
+ )); |
+ c.close(); |
+ }); |
+ |
+ test("join-single", () { |
+ StreamController c = new StreamController(); |
+ c.stream.join("X").then(expectAsync( |
+ (String s) => expect(s, equals("foo")) |
+ )); |
+ c.add("foo"); |
+ c.close(); |
+ }); |
+ |
+ test("join-three", () { |
+ StreamController c = new StreamController(); |
+ c.stream.join("X").then(expectAsync( |
+ (String s) => expect(s, equals("fooXbarXbaz")) |
+ )); |
+ c.add("foo"); |
+ c.add("bar"); |
+ c.add("baz"); |
+ c.close(); |
+ }); |
+ |
+ test("join-three-non-string", () { |
+ StreamController c = new StreamController(); |
+ c.stream.join("X").then(expectAsync( |
+ (String s) => expect(s, equals("fooXbarXbaz")) |
+ )); |
+ c.add(new Foo("foo")); |
+ c.add(new Foo("bar")); |
+ c.add(new Foo("baz")); |
+ c.close(); |
+ }); |
+ |
+ test("join-error", () { |
+ StreamController c = new StreamController(); |
+ c.stream.join("X").catchError(expectAsync( |
+ (String s) => expect(s, equals("BAD!")) |
+ )); |
+ c.add(new Foo("foo")); |
+ c.add(new Foo("bar")); |
+ c.add(new Bad()); |
+ c.add(new Foo("baz")); |
+ c.close(); |
+ }); |
+} |
+ |
+class Foo { |
+ String value; |
+ Foo(this.value); |
+ String toString() => value; |
+} |
+ |
+class Bad { |
+ Bad(); |
+ String toString() => throw "BAD!"; |
+} |