Index: tests/lib/async/stream_subscription_as_future_test.dart |
diff --git a/tests/lib/async/stream_subscription_as_future_test.dart b/tests/lib/async/stream_subscription_as_future_test.dart |
index ef868e28fc7308d7399a8d89e28e9e14af7f7d51..ac1293b0297ba9b8c1f9d429c89b22e9f0d21680 100644 |
--- a/tests/lib/async/stream_subscription_as_future_test.dart |
+++ b/tests/lib/async/stream_subscription_as_future_test.dart |
@@ -40,6 +40,18 @@ main() { |
})); |
}); |
+ test("subscription.asStream different type", () { |
+ Stream stream = new Stream<int>.fromIterable([1, 2, 3]); |
+ var asyncCallback = expectAsync(() => {}); |
+ var output = []; |
+ var subscription = stream.listen((x) { output.add(x); }); |
+ subscription.asFuture("string").then((String o) { |
+ Expect.listEquals([1, 2, 3], output); |
+ Expect.equals("string", o); |
+ asyncCallback(); |
+ }); |
+ }); |
+ |
test("subscription.asStream failure", () { |
StreamController controller = new StreamController(sync: true); |
[1, 2, 3].forEach(controller.add); |