Change hasSubscribers to hasListener.

sdk/lib/async/stream.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.async;
 
 // -------------------------------------------------------------------
 // Core Stream types
 // -------------------------------------------------------------------
 
@@ skipping 114 matching lines @@
             Duration elapsed = watch.elapsed;
             watch.start();
             timer = new Timer(period - elapsed, () {
               timer = null;
               startPeriodicTimer();
               sendEvent();
             });
           }
         },
         onSubscriptionStateChange: () {
-          if (controller.hasSubscribers) {
+          if (controller.hasListener) {
             watch.start();
             startPeriodicTimer();
           } else {
             if (timer != null) timer.cancel();
             timer = null;
           }
         });
     return controller.stream;
   }
 
@@ skipping 828 matching lines @@
     StreamSubscription subscription;
     controller = new StreamController<T>(
         onPauseStateChange: () {
           if (controller.isPaused) {
             subscription.pause();
           } else {
             subscription.resume();
           }
         },
         onSubscriptionStateChange: () {
-          if (controller.hasSubscribers) {
+          if (controller.hasListener) {
             subscription = transformingStream.listen(
                 controller.add,
                 onError: controller.addError,
                 onDone: controller.close);
           } else {
             subscription.cancel();
           }
         });
     return controller.stream;
   }
@@ skipping 155 matching lines @@
 }
 
 class _EventOutputSinkWrapper<T> extends EventSink<T> {
   _EventOutputSink _sink;
   _EventOutputSinkWrapper(this._sink);
 
   void add(T data) { _sink._sendData(data); }
   void addError(AsyncError error) { _sink._sendError(error); }
   void close() { _sink._sendDone(); }
 }