Add zone support to streams.

sdk/lib/async/future_impl.dart

Index: sdk/lib/async/future_impl.dart
diff --git a/sdk/lib/async/future_impl.dart b/sdk/lib/async/future_impl.dart
index 9223a18eed171a9d36c82e42339810299486dae8..be0b7a23229fff9d0acee3ff592698f11332e542 100644
--- a/sdk/lib/async/future_impl.dart
+++ b/sdk/lib/async/future_impl.dart
@@ -23,7 +23,7 @@ abstract class _Completer<T> implements Completer<T> {
     if (_isComplete) throw new StateError("Future already completed");
     _isComplete = true;
     _FutureImpl futureImpl = future;
-    futureImpl._zone.unexpectCallback();
+    futureImpl._zone.cancelCallbackExpectation();
     _setFutureValue(value);
   }
 
@@ -36,7 +36,7 @@ abstract class _Completer<T> implements Completer<T> {
     }
     _FutureImpl futureImpl = future;
     if (futureImpl._inSameErrorZone(_Zone.current)) {
-      futureImpl._zone.unexpectCallback();
+      futureImpl._zone.cancelCallbackExpectation();
       _setFutureError(error);
     } else {
       _Zone.current.handleUncaughtError(error);