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 import 'dart:async'; | 5 import 'dart:async'; |
6 | 6 |
7 import 'package:unittest/src/util/multi_channel.dart'; | 7 import 'package:test/src/util/multi_channel.dart'; |
8 import 'package:unittest/unittest.dart'; | 8 import 'package:test/test.dart'; |
9 | 9 |
10 import '../utils.dart'; | 10 import '../utils.dart'; |
11 | 11 |
12 void main() { | 12 void main() { |
13 var oneToTwo; | 13 var oneToTwo; |
14 var twoToOne; | 14 var twoToOne; |
15 var channel1; | 15 var channel1; |
16 var channel2; | 16 var channel2; |
17 setUp(() { | 17 setUp(() { |
18 oneToTwo = new StreamController(); | 18 oneToTwo = new StreamController(); |
(...skipping 282 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
301 test("emits an error, the error is sent only to the default channel", () { | 301 test("emits an error, the error is sent only to the default channel", () { |
302 channel1.stream.listen(expectAsync((_) {}, count: 0), | 302 channel1.stream.listen(expectAsync((_) {}, count: 0), |
303 onError: expectAsync((error) => expect(error, equals("oh no")))); | 303 onError: expectAsync((error) => expect(error, equals("oh no")))); |
304 virtual1.stream.listen(expectAsync((_) {}, count: 0), | 304 virtual1.stream.listen(expectAsync((_) {}, count: 0), |
305 onError: expectAsync((_) {}, count: 0)); | 305 onError: expectAsync((_) {}, count: 0)); |
306 | 306 |
307 twoToOne.addError("oh no"); | 307 twoToOne.addError("oh no"); |
308 }); | 308 }); |
309 }); | 309 }); |
310 } | 310 } |
OLD | NEW |