| Index: tests/lib/async/stream_controller_test.dart
|
| diff --git a/tests/lib/async/stream_controller_test.dart b/tests/lib/async/stream_controller_test.dart
|
| index 3407614088eca3d13e98b6e4a89b37dde2b67e73..685222d43b743e6343dd8798033bdbaf9efaf8d0 100644
|
| --- a/tests/lib/async/stream_controller_test.dart
|
| +++ b/tests/lib/async/stream_controller_test.dart
|
| @@ -657,6 +657,22 @@ void testAsBroadcastListenAfterClosePaused() {
|
| });
|
| }
|
|
|
| +void testEventInListen() {
|
| + asyncStart();
|
| + // Regression test for http://dartbug.com/19722
|
| + var c;
|
| + void send() {
|
| + c.add(1);
|
| + }
|
| + int i = 1;
|
| + c = new StreamController.broadcast(onListen: send, sync: true);
|
| + c.stream.listen((v) {
|
| + Expect.equals(i++, v);
|
| + }, onDone: asyncEnd);
|
| + c.add(2);
|
| + c.close();
|
| +}
|
| +
|
| main() {
|
| asyncStart();
|
| testMultiController();
|
| @@ -674,5 +690,6 @@ main() {
|
| testBroadcastListenAfterClosePaused();
|
| testAsBroadcastListenAfterClose();
|
| testAsBroadcastListenAfterClosePaused();
|
| + testEventInListen();
|
| asyncEnd();
|
| }
|
|
|