| Index: tests/lib_strong/async/stream_periodic6_test.dart
 | 
| diff --git a/tests/lib_strong/async/stream_periodic6_test.dart b/tests/lib_strong/async/stream_periodic6_test.dart
 | 
| index 1d4ffa332b05adc41b2fd3dfe73eaef735d2c1e5..b413613b80f9b4cda87d1a5bb10cb92bb44dc5ce 100644
 | 
| --- a/tests/lib_strong/async/stream_periodic6_test.dart
 | 
| +++ b/tests/lib_strong/async/stream_periodic6_test.dart
 | 
| @@ -10,18 +10,17 @@ import 'package:unittest/unittest.dart';
 | 
|  
 | 
|  main() {
 | 
|    test("stream-periodic1", () {
 | 
| -    Stream stream = new Stream.periodic(const Duration(milliseconds: 1),
 | 
| -                                        (i) {
 | 
| -                                          if (i == 3) throw 42;
 | 
| -                                          return i;
 | 
| -                                        });
 | 
| +    Stream stream = new Stream.periodic(const Duration(milliseconds: 1), (i) {
 | 
| +      if (i == 3) throw 42;
 | 
| +      return i;
 | 
| +    });
 | 
|      int expected = 0;
 | 
|      var subscription;
 | 
| -    subscription = stream.listen(expectAsync((data) {
 | 
| -      expect(data, expected++);
 | 
| -      if (expected == 5) subscription.cancel();
 | 
| -    }, count: 4),
 | 
| -    onError: expectAsync((e, s) {
 | 
| +    subscription = stream.listen(
 | 
| +        expectAsync((data) {
 | 
| +          expect(data, expected++);
 | 
| +          if (expected == 5) subscription.cancel();
 | 
| +        }, count: 4), onError: expectAsync((e, s) {
 | 
|        expect(e, 42);
 | 
|        expected++;
 | 
|      }));
 | 
| 
 |