| OLD | NEW |
| 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2016, 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:stream_channel/stream_channel.dart'; | 7 import 'package:stream_channel/stream_channel.dart'; |
| 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 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( |
| 21 channel2 = new MultiChannel(oneToTwo.stream, twoToOne.sink); | 21 new StreamChannel(twoToOne.stream, oneToTwo.sink)); |
| 22 channel2 = new MultiChannel( |
| 23 new StreamChannel(oneToTwo.stream, twoToOne.sink)); |
| 22 }); | 24 }); |
| 23 | 25 |
| 24 group("the default virtual channel", () { | 26 group("the default virtual channel", () { |
| 25 test("begins connected", () { | 27 test("begins connected", () { |
| 26 var first = true; | 28 var first = true; |
| 27 channel2.stream.listen(expectAsync((message) { | 29 channel2.stream.listen(expectAsync((message) { |
| 28 if (first) { | 30 if (first) { |
| 29 expect(message, equals("hello")); | 31 expect(message, equals("hello")); |
| 30 first = false; | 32 first = false; |
| 31 } else { | 33 } else { |
| (...skipping 269 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", () { | 303 test("emits an error, the error is sent only to the default channel", () { |
| 302 channel1.stream.listen(expectAsync((_) {}, count: 0), | 304 channel1.stream.listen(expectAsync((_) {}, count: 0), |
| 303 onError: expectAsync((error) => expect(error, equals("oh no")))); | 305 onError: expectAsync((error) => expect(error, equals("oh no")))); |
| 304 virtual1.stream.listen(expectAsync((_) {}, count: 0), | 306 virtual1.stream.listen(expectAsync((_) {}, count: 0), |
| 305 onError: expectAsync((_) {}, count: 0)); | 307 onError: expectAsync((_) {}, count: 0)); |
| 306 | 308 |
| 307 twoToOne.addError("oh no"); | 309 twoToOne.addError("oh no"); |
| 308 }); | 310 }); |
| 309 }); | 311 }); |
| 310 } | 312 } |
| OLD | NEW |