Rework Timer interface.

sdk/lib/async/future_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;
 
 deprecatedFutureValue(_FutureImpl future) =>
   future._isComplete ? future._resultOrListeners : null;
 
 
@@ skipping 161 matching lines @@
       return _handleError(f, test);
     }
   }
 
   Future<T> whenComplete(action()) {
     _WhenFuture<T> whenFuture = new _WhenFuture<T>(action);
     if (!_isComplete) {
       _addListener(whenFuture);
     } else if (_hasValue) {
       T value = _resultOrListeners;
-      new Timer(0, (_) {
+      Timer.run(() {
         whenFuture._sendValue(value);
       });
     } else {
       assert(_hasError);
       _clearUnhandledError();
       AsyncError error = _resultOrListeners;
-      new Timer(0, (_) {
+      Timer.run(() {
         whenFuture._sendError(error);
       });
     }
     return whenFuture;
   }
 
   /** Handle a late listener on a completed future with a value. */
   Future _handleValue(onValue(var value)) {
     assert(_hasValue);
     _ThenFuture thenFuture = new _ThenFuture(onValue);
     T value = _resultOrListeners;
-    new Timer(0, (_) { thenFuture._sendValue(value); });
+    Timer.run(() { thenFuture._sendValue(value); });
     return thenFuture;
   }
 
   /** Handle a late listener on a completed future with an error. */
   Future _handleError(onError(AsyncError error), bool test(error)) {
     assert(_hasError);
     _clearUnhandledError();
     AsyncError error = _resultOrListeners;
     _CatchErrorFuture errorFuture = new _CatchErrorFuture(onError, test);
-    new Timer(0, (_) { errorFuture._sendError(error); });
+    Timer.run(() { errorFuture._sendError(error); });
     return errorFuture;
   }
 
   Stream<T> asStream() => new Stream.fromFuture(this);
 
   void _setValue(T value) {
     if (_isComplete) throw new StateError("Future already completed");
     _FutureListener listeners = _removeListeners();
     _state = _VALUE;
     _resultOrListeners = value;
@@ skipping 19 matching lines @@
       listeners = listener._nextListener;
       listener._nextListener = null;
       listener._sendError(error);
     } while (listeners != null);
   }
 
   void _scheduleUnhandledError() {
     _state |= _UNHANDLED_ERROR;
     // Wait for the rest of the current event's duration to see
     // if a subscriber is added to handle the error.
-    new Timer(0, (_) {
+    Timer.run(() {
       if (_hasUnhandledError) {
         // No error handler has been added since the error was set.
         _clearUnhandledError();
         AsyncError error = _resultOrListeners;
         print("Uncaught Error: ${error.error}");
         if (error.stackTrace != null) {
           print("Stack Trace:\n${error.stackTrace}\n");
         }
         throw error.error;
       }
@@ skipping 259 matching lines @@
   Future catchError(function(AsyncError error), {bool test(var error)}) {
     return _future.catchError(function, test: test);
   }
 
   Future<T> whenComplete(action()) {
     return _future.whenComplete(action);
   }
 
   Stream<T> asStream() => new Stream.fromFuture(_future);
 }