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

Side by Side Diff: test/subscription_stream_test.dart

Issue 2161283002: Fix Dart 1.17 strong-mode warnings. (Closed) Base URL: git@github.com:dart-lang/async.git@master
Patch Set: Created 4 years, 5 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
« no previous file with comments | « test/stream_zip_test.dart ('k') | test/typed_wrapper/future_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) 2015, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2015, 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 import "dart:async"; 5 import "dart:async";
6 6
7 import "package:async/async.dart" show SubscriptionStream; 7 import "package:async/async.dart" show SubscriptionStream;
8 import "package:test/test.dart"; 8 import "package:test/test.dart";
9 9
10 import "utils.dart"; 10 import "utils.dart";
11 11
12 main() { 12 main() {
13 test("subscription stream of an entire subscription", () async { 13 test("subscription stream of an entire subscription", () async {
14 var stream = createStream(); 14 var stream = createStream();
15 var subscription = stream.listen(null); 15 var subscription = stream.listen(null);
16 var subscriptionStream = new SubscriptionStream<int>(subscription); 16 var subscriptionStream = new SubscriptionStream<int>(subscription);
17 await flushMicrotasks(); 17 await flushMicrotasks();
18 expect(subscriptionStream.toList(), completion([1, 2, 3, 4])); 18 expect(subscriptionStream.toList(), completion([1, 2, 3, 4]));
19 }); 19 });
20 20
21 test("subscription stream after two events", () async { 21 test("subscription stream after two events", () async {
22 var stream = createStream(); 22 var stream = createStream();
23 var skips = 0; 23 var skips = 0;
24 var completer = new Completer(); 24 var completer = new Completer();
25 var subscription; 25 StreamSubscription<int> subscription;
26 subscription = stream.listen((value) { 26 subscription = stream.listen((value) {
27 ++skips; 27 ++skips;
28 expect(value, skips); 28 expect(value, skips);
29 if (skips == 2) { 29 if (skips == 2) {
30 completer.complete(new SubscriptionStream<int>(subscription)); 30 completer.complete(new SubscriptionStream<int>(subscription));
31 } 31 }
32 }); 32 });
33 var subscriptionStream = await completer.future; 33 var subscriptionStream = await completer.future;
34 await flushMicrotasks(); 34 await flushMicrotasks();
35 expect(subscriptionStream.toList(), completion([3, 4])); 35 expect(subscriptionStream.toList(), completion([3, 4]));
(...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after
161 yield 4; 161 yield 4;
162 } 162 }
163 163
164 Stream<int> createErrorStream([Completer onCancel]) async* { 164 Stream<int> createErrorStream([Completer onCancel]) async* {
165 bool canceled = true; 165 bool canceled = true;
166 try { 166 try {
167 yield 1; 167 yield 1;
168 await flushMicrotasks(); 168 await flushMicrotasks();
169 yield 2; 169 yield 2;
170 await flushMicrotasks(); 170 await flushMicrotasks();
171 yield* new Future.error("To err is divine!").asStream(); 171 yield* new Future<int>.error("To err is divine!").asStream();
172 await flushMicrotasks(); 172 await flushMicrotasks();
173 yield 4; 173 yield 4;
174 await flushMicrotasks(); 174 await flushMicrotasks();
175 canceled = false; 175 canceled = false;
176 } finally { 176 } finally {
177 // Completes before the "done", but should be after all events. 177 // Completes before the "done", but should be after all events.
178 if (canceled && onCancel != null) { 178 if (canceled && onCancel != null) {
179 await flushMicrotasks(); 179 await flushMicrotasks();
180 onCancel.complete(); 180 onCancel.complete();
181 } 181 }
182 } 182 }
183 } 183 }
184 184
185 Stream<int> createLongStream() async* { 185 Stream<int> createLongStream() async* {
186 for (int i = 0; i < 200; i++) yield i; 186 for (int i = 0; i < 200; i++) yield i;
187 } 187 }
OLDNEW
« no previous file with comments | « test/stream_zip_test.dart ('k') | test/typed_wrapper/future_test.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698