Rework Timer interface.

sdk/lib/io/http_impl.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.
 
 part of dart.io;
 
 // The close queue handles graceful closing of HTTP connections. When
 // a connection is added to the queue it will enter a wait state
 // waiting for all data written and possibly socket shutdown from
 // peer.
@@ skipping 484 matching lines @@
   void _streamClose() {
     _ensureHeadersSent();
     _state = _HttpRequestResponseBase.DONE;
     // Stop tracking no pending write events.
     _httpConnection._onNoPendingWrites = null;
     // Ensure that any trailing data is written.
     _writeDone();
     // Indicate to the connection that the response handling is done.
     _httpConnection._responseClosed();
     if (_streamClosedHandler != null) {
-      new Timer(0, (_) => _streamClosedHandler());
+      Timer.run(_streamClosedHandler);
     }
   }
 
   void _streamSetNoPendingWriteHandler(callback()) {
     if (_state != _HttpRequestResponseBase.DONE) {
       _httpConnection._onNoPendingWrites = callback;
     }
   }
 
   void _streamSetClosedHandler(callback()) {
@@ skipping 690 matching lines @@
 
   void _streamClose() {
     _ensureHeadersSent();
     _state = _HttpRequestResponseBase.DONE;
     // Stop tracking no pending write events.
     _httpConnection._onNoPendingWrites = null;
     // Ensure that any trailing data is written.
     _writeDone();
     _connection._requestClosed();
     if (_streamClosedHandler != null) {
-      new Timer(0, (_) => _streamClosedHandler());
+      Timer.run(_streamClosedHandler);
     }
   }
 
   void _streamSetNoPendingWriteHandler(callback()) {
     if (_state != _HttpRequestResponseBase.DONE) {
       _httpConnection._onNoPendingWrites = callback;
     }
   }
 
   void _streamSetClosedHandler(callback()) {
@@ skipping 822 matching lines @@
           socket.onError = null;
           _SocketConnection socketConn =
               new _SocketConnection(connectHost, connectPort, socket);
           _activeSockets.add(socketConn);
           _connectionOpened(socketConn, connection, !proxy.isDirect);
         };
       } else {
         _SocketConnection socketConn = socketConnections.removeFirst();
         socketConn._markRetrieved();
         _activeSockets.add(socketConn);
-        new Timer(0, (ignored) =>
+        Timer.run(() =>
                   _connectionOpened(socketConn, connection, !proxy.isDirect));
 
         // Get rid of eviction timer if there are no more active connections.
         if (socketConnections.isEmpty) _openSockets.remove(key);
         if (_openSockets.isEmpty) _cancelEvictionTimer();
       }
     }
 
     // Find out if we want a secure socket.
     bool is_secure = (url.scheme == "https");
@@ skipping 74 matching lines @@
                 }
               }
             });
 
         // Remove the keys for which here are no more open connections.
         emptyKeys.forEach((String key) => _openSockets.remove(key));
 
         // If all connections where evicted cancel the eviction timer.
         if (_openSockets.isEmpty) _cancelEvictionTimer();
       }
-      _evictionTimer = new Timer.repeating(10000, _handleEviction);
+      _evictionTimer = new Timer.repeating(const Duration(seconds: 10),
+                                           _handleEviction);
     }
 
     // Return connection.
     _activeSockets.remove(socketConn);
     sockets.addFirst(socketConn);
   }
 
   void _closeSocketConnection(_SocketConnection socketConn) {
     socketConn._close();
     _activeSockets.remove(socketConn);
@@ skipping 158 matching lines @@
 
 
 class _RedirectInfo implements RedirectInfo {
   const _RedirectInfo(int this.statusCode,
                       String this.method,
                       Uri this.location);
   final int statusCode;
   final String method;
   final Uri location;
 }