Upgrading tests with unittest deprecations

tests/lib/async/stream_state_helper.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.
 
 library stream_state_helper;
 
 import "../../../pkg/unittest/lib/unittest.dart";
 import "dart:async";
 import "dart:collection";
 
@@ skipping 46 matching lines @@
   int _subscriptionIdCounter = 0;
   Function _onComplete;
 
   StreamProtocolTest.broadcast({ bool sync: false })
       : isBroadcast = true, isAsBroadcast = false {
     _controller = new StreamController.broadcast(
         sync: sync,
         onListen: _onListen,
         onCancel: _onCancel);
     _controllerStream = _controller.stream;
-    _onComplete = expectAsync0((){
+    _onComplete = expectAsync((){
       _onComplete = null;  // Being null marks the test as being complete.
     });
   }
 
   StreamProtocolTest({ bool sync: false })
     : isBroadcast = false, isAsBroadcast = false {
     _controller = new StreamController(
         sync: sync,
         onListen: _onListen,
         onPause: _onPause,
         onResume: _onResume,
         onCancel: _onCancel);
     _controllerStream = _controller.stream;
-    _onComplete = expectAsync0((){
+    _onComplete = expectAsync((){
       _onComplete = null;  // Being null marks the test as being complete.
     });
   }
 
   StreamProtocolTest.asBroadcast({ bool sync: false })
       : isBroadcast = false, isAsBroadcast = true {
     _controller = new StreamController(
         sync: sync,
         onListen: _onListen,
         onPause: _onPause,
         onResume: _onResume,
         onCancel: _onCancel);
     _controllerStream = _controller.stream.asBroadcastStream(
         onListen: _onBroadcastListen,
         onCancel: _onBroadcastCancel);
-    _onComplete = expectAsync0((){
+    _onComplete = expectAsync((){
       _onComplete = null;  // Being null marks the test as being complete.
     });
   }
 
   // Actions on the stream and controller.
   void add(var data) { _controller.add(data); }
   void error(var error) { _controller.addError(error); }
   void close() { _controller.close(); }
 
   SubscriptionProtocolTest listen({bool cancelOnError : false}) {
@@ skipping 258 matching lines @@
       buf.write("\n");
     }
     throw "Unexpected event:\n$message\nAll expectations:\n$buf";
   }
 }
 
 class Event {
   Function _action;
   StackTrace _stackTrace;
   Event(void action())
-      : _action = (action == null) ? null : expectAsync0(action) {
+      : _action = (action == null) ? null : expectAsync(action) {
     try { throw 0; } catch (_, s) { _stackTrace = s; }
   }
   Event.broadcast(void action(StreamSubscription sub))
-      : _action = (action == null) ? null : expectAsync1(action) {
+      : _action = (action == null) ? null : expectAsync(action) {
     try { throw 0; } catch (_, s) { _stackTrace = s; }
   }
 
   bool matchData(int id, var data) {
     return false;
   }
 
   bool matchError(int id, e) {
     return false;
   }
@@ skipping 189 matching lines @@
   }
 
   bool _testBroadcastCancel() {
     _actual = "*[BroadcastCancel]";
     return true;
   }
 
   /** Returns a representation of the event it was tested against. */
   String toString() => _actual;
 }