Rework Timer interface.

tests/standalone/io/socket_stream_close_test.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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 //
 // Test socket close events.
@@ skipping 15 matching lines @@
         _dataEvents = 0,
         _closeEvents = 0,
         _errorEvents = 0,
         _iterations = 0 {
     _sendPort = spawnFunction(startSocketCloseServer);
     initialize();
   }
 
   void proceed() {
     if (_iterations < ITERATIONS) {
-      new Timer(0, sendData);
+      Timer.run(sendData);
     } else {
       shutdown();
     }
   }
 
-  void sendData(Timer timer) {
+  void sendData() {
 
     void dataHandler() {
       switch (_mode) {
         case 0:
         case 1:
         case 2:
           Expect.fail("No data expected");
           break;
         case 3:
         case 4:
@@ skipping 257 matching lines @@
 
     connection.inputStream.onData = dataHandler;
     connection.inputStream.onClosed = closeHandler;
     connection.onError = errorHandler;
   }
 
   void errorHandlerServer(Exception e) {
     Expect.fail("Server socket error");
   }
 
-  waitForResult(Timer timer) {
+  waitForResult() {
     // Make sure all iterations have been run. In multiple of these
     // scenarios it is possible to get the SERVERSHUTDOWN message
     // before we have received the last close event on the
     // server. In these cases we wait for the correct number of
     // close events.
     if (_iterations == ITERATIONS &&
         (_closeEvents == ITERATIONS ||
          (_mode == 2 || _mode == 3 || _mode == 4))) {
       switch (_mode) {
         case 0:
@@ skipping 18 matching lines @@
           Expect.equals(ITERATIONS, _closeEvents);
           break;
         default:
           Expect.fail("Unknown test mode");
       }
       Expect.equals(0, _errorEvents);
       _server.close();
       port.close();
       _donePort.send(null);
     } else {
-      new Timer(100, waitForResult);
+      new Timer(new Duration(milliseconds: 100), waitForResult);
     }
   }
 
   void dispatch(message, replyTo) {
     _donePort = replyTo;
     if (message != SERVERSHUTDOWN) {
       _readBytes = 0;
       _errorEvents = 0;
       _dataEvents = 0;
       _closeEvents = 0;
       _iterations = 0;
       _mode = message;
       _server = new ServerSocket(HOST, 0, 10);
       Expect.equals(true, _server != null);
       _server.onConnection = (connection) {
         var data = new ConnectionData(connection);
         connectionHandler(data);
       };
       _server.onError = errorHandlerServer;
       replyTo.send(_server.port, null);
     } else {
-      new Timer(0, waitForResult);
+      Timer.run(waitForResult);
     }
   }
 
   ServerSocket _server;
   SendPort _donePort;
   int _readBytes;
   int _errorEvents;
   int _dataEvents;
   int _closeEvents;
   int _iterations;
@@ skipping 17 matching lines @@
   var tests = 9;
   var port = new ReceivePort();
   var completed = 0;
   port.receive((message, ignore) {
     if (++completed == tests) port.close();
   });
   for (var i = 0; i < tests; i++) {
     new SocketClose.start(i, port.toSendPort());
   }
 }