Rework Timer interface.

sdk/lib/async/stream_impl.dart

 // Copyright (c) 2012, 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.
 
 part of dart.async;
 
 // States shared by single/multi stream implementations.
 
 /// Initial and default state where the stream can receive and send events.
 const int _STREAM_OPEN = 0;
@@ skipping 1008 matching lines @@
    * due to a second event in the current cycle, the timer is canceled again.
    */
   Timer scheduleTimer = null;
 
   bool get isEmpty;
 
   bool get isScheduled => scheduleTimer != null;
 
   void schedule(_StreamImpl stream) {
     if (isScheduled) return;
-    scheduleTimer = new Timer(0, (_) {
+    scheduleTimer = Timer.run(() {
       scheduleTimer = null;
       stream._handlePendingEvents();
     });
   }
 
   void cancelSchedule() {
     assert(isScheduled);
     scheduleTimer.cancel();
     scheduleTimer = null;
   }
@@ skipping 37 matching lines @@
   _DoneHandler _handler;
   Timer _timer;
   int _pauseCount = 0;
 
   _DoneSubscription(this._handler) {
     _delayDone();
   }
 
   void _delayDone() {
     assert(_timer == null && _pauseCount == 0);
-    _timer = new Timer(0, (_) {
+    _timer = Timer.run(() {
       if (_handler != null) _handler();
     });
   }
 
   bool get _isComplete => _timer == null && _pauseCount == 0;
 
   void onData(void handleAction(T value)) {}
 
   void onError(void handleError(AsyncError error)) {}
 
@@ skipping 63 matching lines @@
                                      onError: this._signalError,
                                      onDone: this._close);
     } else {
       // TODO(lrn): Check why this can happen.
       if (_subscription == null) return;
       _subscription.cancel();
       _subscription = null;
     }
   }
 }