Run runAsync callbacks of futures in their zone.

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;
 
 /** The onValue and onError handlers return either a value or a future */
 typedef dynamic _FutureOnValue<T>(T value);
 typedef dynamic _FutureOnError(error);
 /** Test used by [Future.catchError] to handle skip some errors. */
@@ skipping 206 matching lines @@
   void _setError(Object error) {
     assert(!_isComplete);  // But may have a completion pending.
     _state = _ERROR;
     _resultOrListeners = error;
   }
 
   void _addListener(_Future listener) {
     assert(listener._nextListener == null);
     if (_isComplete) {
       // Handle late listeners asynchronously.
-      runAsync(() {
+      _zone.runAsync(() {
         _propagateToListeners(this, listener);
-      });
+      }, _zone);
     } else {
       listener._nextListener = _resultOrListeners;
       _resultOrListeners = listener;
     }
   }
 
   _Future _removeListeners() {
     // Reverse listeners before returning them, so the resulting list is in
     // subscription order.
     assert(!_isComplete);
@@ skipping 94 matching lines @@
         (value is! _Future || !(value as _Future)._isComplete)) {
       // Case 2 from above. We need to register.
       // Note that we are still completing asynchronously: either we register
       // through .then (in which case the completing is asynchronous), or we
       // have a _Future which isn't complete yet.
       _complete(value);
       return;
     }
 
     _markPendingCompletion();
-    runAsync(() {
-      _complete(value);
-    });
+    _zone.runAsync(() { _complete(value); }, _zone);
   }
 
   void _asyncCompleteError(error, [StackTrace stackTrace]) {
     assert(!_isComplete);
     assert(_onValue == null);
     assert(_onError == null);
     assert(_whenCompleteAction == null);
     assert(_errorTest == null);
 
     _markPendingCompletion();
-    runAsync(() {
-      _completeError(error, stackTrace);
-    });
+    _zone.runAsync(() { _completeError(error, stackTrace); }, _zone);
   }
 
   /**
    * Propagates the value/error of [source] to its [listeners].
    *
    * Unlinks all listeners and propagates the source to each listener
    * separately.
    */
   static void _propagateMultipleListeners(_Future source, _Future listeners) {
     assert(listeners != null);
@@ skipping 145 matching lines @@
         listener._setValue(listenerValueOrError);
       } else {
         listeners = listener._removeListeners();
         listener._setError(listenerValueOrError);
       }
       // Prepare for next round.
       source = listener;
     }
   }
 }