OLD | NEW |
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 library async_start_test; | 5 library async_star_test; |
6 | 6 |
7 import "package:unittest/unittest.dart"; | 7 import "package:unittest/unittest.dart"; |
8 import "dart:async"; | 8 import "dart:async"; |
9 | 9 |
10 main() { | 10 main() { |
11 group("basic", () { | 11 group("basic", () { |
12 test("empty", () { | 12 test("empty", () { |
13 f() async* {} | 13 f() async* {} |
14 return f().toList().then((v) { | 14 return f().toList().then((v) { |
15 expect(v, equals([])); | 15 expect(v, equals([])); |
(...skipping 760 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
776 var getErrors = new StreamTransformer.fromHandlers( | 776 var getErrors = new StreamTransformer.fromHandlers( |
777 handleData:(data, sink) { fail("Unexpected value"); }, | 777 handleData:(data, sink) { fail("Unexpected value"); }, |
778 handleError: (e, s, sink) { sink.add(e); }, | 778 handleError: (e, s, sink) { sink.add(e); }, |
779 handleDone: (sink) { sink.close(); }); | 779 handleDone: (sink) { sink.close(); }); |
780 | 780 |
781 class NotAStream { | 781 class NotAStream { |
782 listen(oData, {onError, onDone, cancelOnError}) { | 782 listen(oData, {onError, onDone, cancelOnError}) { |
783 fail("Not implementing Stream."); | 783 fail("Not implementing Stream."); |
784 } | 784 } |
785 } | 785 } |
OLD | NEW |