Rework Timer interface.

sdk/lib/io/stream_util.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.io;
 
 abstract class _BaseDataInputStream {
   int available();
 
   List<int> read([int len]) {
@@ skipping 81 matching lines @@
   }
 
   void _cancelScheduledDataCallback() {
     if (_scheduledDataCallback != null) {
       _scheduledDataCallback.cancel();
       _scheduledDataCallback = null;
     }
   }
 
   void _checkScheduleCallbacks() {
-    void issueDataCallback(Timer timer) {
+    void issueDataCallback() {
       _scheduledDataCallback = null;
       if (_clientDataHandler != null) {
         _clientDataHandler();
         _checkScheduleCallbacks();
       }
     }
 
-    void issueCloseCallback(Timer timer) {
+    void issueCloseCallback() {
       _scheduledCloseCallback = null;
       _closeCallbackCalled = true;
       if (_clientCloseHandler != null) _clientCloseHandler();
     }
 
     // Schedule data callback if there is more data to read. Schedule
     // close callback once when all data has been read. Only schedule
     // a new callback if the previous one has actually been called.
     if (!_closeCallbackCalled) {
       if (available() > 0) {
         if (_scheduledDataCallback == null) {
-          _scheduledDataCallback = new Timer(0, issueDataCallback);
+          _scheduledDataCallback = Timer.run(issueDataCallback);
         }
       } else if (_streamMarkedClosed && _scheduledCloseCallback == null) {
         _cancelScheduledDataCallback();
         _close();
-        _scheduledCloseCallback = new Timer(0, issueCloseCallback);
+        _scheduledCloseCallback = Timer.run(issueCloseCallback);
       }
     }
   }
 
   // When this is set to true the stream is marked closed. When a
   // stream is marked closed no more data can arrive and the value
   // from available is now all remaining data. If this is true and the
   // value of available is zero the close handler is called.
   bool _streamMarkedClosed = false;
 
@@ skipping 64 matching lines @@
   void _reportError(e) {
     if (_onError != null) {
       _onError(e);
     } else {
       throw e;
     }
   }
 
   Function _onError;
 }