pkg/async: updates for unittest deprecations

pkg/async/test/stream_zip_test.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import "dart:async";
 import "package:async/stream_zip.dart";
 import "package:unittest/unittest.dart";
 
 /// Create an error with the same values as [base], except that it throwsA
 /// when seeing the value [errorValue].
@@ skipping 20 matching lines @@
 }
 
 /// Counter used to give varying delays for streams.
 int ctr = 0;
 
 main() {
   // Test that zipping [streams] gives the results iterated by [expectedData].
   testZip(Iterable streams, Iterable expectedData) {
     List data = [];
     Stream zip = new StreamZip(streams);
-    zip.listen(data.add, onDone: expectAsync0(() {
+    zip.listen(data.add, onDone: expectAsync(() {
       expect(data, equals(expectedData));
     }));
   }
 
   test("Basic", () {
     testZip([mks([1, 2, 3]), mks([4, 5, 6]), mks([7, 8, 9])],
             [[1, 4, 7], [2, 5, 8], [3, 6, 9]]);
   });
 
   test("Uneven length 1", () {
@@ skipping 96 matching lines @@
       Timer.run(() { controller.addError("BAD-6"); });
       s.close();
     });
     testZip([mks([1, 2, 3]).transform(trans),
              mks([4, 5, 6]).transform(trans),
              controller.stream],
            [[1, 4, 7], [2, 5, 8], [3, 6, 9]]);
   });
 
   test("Pause/Resume", () {
-    var done = expectAsync0((){});  // Call to complete test.
+    var done = expectAsync((){});  // Call to complete test.
 
     int sc1p = 0;
     StreamController c1 = new StreamController(
       onPause: () {
         sc1p++;
       },
       onResume: () {
         sc1p--;
       });
 
@@ skipping 39 matching lines @@
     c1..add(1)..add(3)..add(5)..add(7)..close();
     c2..add(2)..add(4);
   });
 
   test("pause-resume2", () {
     var s1 = new Stream.fromIterable([0, 2, 4, 6, 8]);
     var s2 = new Stream.fromIterable([1, 3, 5, 7]);
     var sz = new StreamZip([s1, s2]);
     int ctr = 0;
     var sub;
-    sub = sz.listen(expectAsync1((v) {
+    sub = sz.listen(expectAsync((v) {
       expect(v, equals([ctr * 2, ctr * 2 + 1]));
       if (ctr == 1) {
         sub.pause(new Future.delayed(const Duration(milliseconds: 25)));
       } else if (ctr == 2) {
         sub.pause();
         new Future.delayed(const Duration(milliseconds: 25)).then((_) {
           sub.resume();
         });
       }
       ctr++;
     }, count: 4));
   });
 }