Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(142)

Side by Side Diff: tests/lib/async/stream_subscription_as_future_test.dart

Issue 16125005: Make new StreamController be async by default. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Address review comments Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « tests/lib/async/stream_state_test.dart ('k') | tests/lib/async/stream_transform_test.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 // Test the Stream.single method. 5 // Test the Stream.single method.
6 library stream_single_test; 6 library stream_single_test;
7 7
8 import "package:expect/expect.dart"; 8 import "package:expect/expect.dart";
9 import 'dart:async'; 9 import 'dart:async';
10 import '../../../pkg/unittest/lib/unittest.dart'; 10 import '../../../pkg/unittest/lib/unittest.dart';
11 11
12 main() { 12 main() {
13 test("subscription.asStream success", () { 13 test("subscription.asStream success", () {
14 Stream stream = new Stream.fromIterable([1, 2, 3]); 14 Stream stream = new Stream.fromIterable([1, 2, 3]);
15 var output = []; 15 var output = [];
16 var subscription = stream.listen((x) { output.add(x); }); 16 var subscription = stream.listen((x) { output.add(x); });
17 subscription.asFuture(output).then(expectAsync1((o) { 17 subscription.asFuture(output).then(expectAsync1((o) {
18 Expect.listEquals([1, 2, 3], o); 18 Expect.listEquals([1, 2, 3], o);
19 })); 19 }));
20 }); 20 });
21 21
22 test("subscription.asStream success2", () { 22 test("subscription.asStream success2", () {
23 StreamController controller = new StreamController(); 23 StreamController controller = new StreamController(sync: true);
24 [1, 2, 3].forEach(controller.add); 24 [1, 2, 3].forEach(controller.add);
25 controller.close(); 25 controller.close();
26 Stream stream = controller.stream; 26 Stream stream = controller.stream;
27 var output = []; 27 var output = [];
28 var subscription = stream.listen((x) { output.add(x); }); 28 var subscription = stream.listen((x) { output.add(x); });
29 subscription.asFuture(output).then(expectAsync1((o) { 29 subscription.asFuture(output).then(expectAsync1((o) {
30 Expect.listEquals([1, 2, 3], o); 30 Expect.listEquals([1, 2, 3], o);
31 })); 31 }));
32 }); 32 });
33 33
34 test("subscription.asStream success 3", () { 34 test("subscription.asStream success 3", () {
35 Stream stream = new Stream.fromIterable([1, 2, 3]).map((x) => x); 35 Stream stream = new Stream.fromIterable([1, 2, 3]).map((x) => x);
36 var output = []; 36 var output = [];
37 var subscription = stream.listen((x) { output.add(x); }); 37 var subscription = stream.listen((x) { output.add(x); });
38 subscription.asFuture(output).then(expectAsync1((o) { 38 subscription.asFuture(output).then(expectAsync1((o) {
39 Expect.listEquals([1, 2, 3], o); 39 Expect.listEquals([1, 2, 3], o);
40 })); 40 }));
41 }); 41 });
42 42
43 test("subscription.asStream failure", () { 43 test("subscription.asStream failure", () {
44 StreamController controller = new StreamController(); 44 StreamController controller = new StreamController(sync: true);
45 [1, 2, 3].forEach(controller.add); 45 [1, 2, 3].forEach(controller.add);
46 controller.addError("foo"); 46 controller.addError("foo");
47 controller.close(); 47 controller.close();
48 Stream stream = controller.stream; 48 Stream stream = controller.stream;
49 var output = []; 49 var output = [];
50 var subscription = stream.listen((x) { output.add(x); }); 50 var subscription = stream.listen((x) { output.add(x); });
51 subscription.asFuture(output).catchError(expectAsync1((error) { 51 subscription.asFuture(output).catchError(expectAsync1((error) {
52 Expect.equals(error, "foo"); 52 Expect.equals(error, "foo");
53 })); 53 }));
54 }); 54 });
55 55
56 test("subscription.asStream failure2", () { 56 test("subscription.asStream failure2", () {
57 Stream stream = new Stream.fromIterable([1, 2, 3, 4]) 57 Stream stream = new Stream.fromIterable([1, 2, 3, 4])
58 .map((x) { 58 .map((x) {
59 if (x == 4) throw "foo"; 59 if (x == 4) throw "foo";
60 return x; 60 return x;
61 }); 61 });
62 var output = []; 62 var output = [];
63 var subscription = stream.listen((x) { output.add(x); }); 63 var subscription = stream.listen((x) { output.add(x); });
64 subscription.asFuture(output).catchError(expectAsync1((error) { 64 subscription.asFuture(output).catchError(expectAsync1((error) {
65 Expect.equals(error, "foo"); 65 Expect.equals(error, "foo");
66 })); 66 }));
67 }); 67 });
68 } 68 }
OLDNEW
« no previous file with comments | « tests/lib/async/stream_state_test.dart ('k') | tests/lib/async/stream_transform_test.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698