| 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:unittest/src/util/multi_channel.dart'; |
| 8 import 'package:unittest/unittest.dart'; | 8 import 'package:unittest/unittest.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(); |
| 19 twoToOne = new StreamController(); | 19 twoToOne = new StreamController(); |
| 20 channel1 = new MultiChannel(twoToOne.stream, oneToTwo.sink); | 20 channel1 = new MultiChannel(twoToOne.stream, oneToTwo.sink); |
| (...skipping 280 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 |