Change hasSubscribers to hasListener.

sdk/lib/io/secure_socket.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.io;
 
 /**
  * A high-level class for communicating securely over a TCP socket, using
  * TLS and SSL. The [SecureSocket] exposes both a [Stream] and an
  * [IOSink] interface, making it ideal for using together with
@@ skipping 373 matching lines @@
       if (_socketClosedWrite) {
         _close();
       }
     }
   }
 
   bool get writeEventsEnabled => _writeEventsEnabled;
 
   void set writeEventsEnabled(bool value) {
     if (value &&
-        _controller.hasSubscribers &&
+        _controller.hasListener &&
         _secureFilter != null &&
         _secureFilter.buffers[WRITE_PLAINTEXT].free > 0) {
       Timer.run(() => _controller.add(RawSocketEvent.WRITE));
     } else {
       _writeEventsEnabled = value;
     }
   }
 
   bool get readEventsEnabled => _readEventsEnabled;
 
@@ skipping 89 matching lines @@
     if (_filterWriteEmpty && _closedWrite && !_socketClosedWrite) {
       // Close _socket for write, by calling shutdown(), to avoid cloning the
       // socket closing code in shutdown().
       shutdown(SocketDirection.SEND);
     }
     if (_status == HANDSHAKE) {
       try {
         _secureHandshake();
       } catch (e) { _reportError(e, "RawSecureSocket error"); }
     } else if (_status == CONNECTED &&
-               _controller.hasSubscribers &&
+               _controller.hasListener &&
                _writeEventsEnabled &&
                _secureFilter.buffers[WRITE_PLAINTEXT].free > 0) {
       // Reset the one-shot handler.
       _writeEventsEnabled = false;
       _controller.add(RawSocketEvent.WRITE);
     }
   }
 
   void _eventDispatcher(RawSocketEvent event) {
     if (event == RawSocketEvent.READ) {
@@ skipping 106 matching lines @@
     if (!_socketClosedRead || !_socketClosedWrite) {
       if (_controller.isPaused) {
         _socketSubscription.pause();
       } else {
         _socketSubscription.resume();
       }
     }
   }
 
   void _onSubscriptionStateChange() {
-    if (_controller.hasSubscribers) {
+    if (_controller.hasListener) {
       // TODO(ajohnsen): Do something here?
     }
   }
 
   void _readEncryptedData() {
     // Read from the socket, and push it through the filter as far as
     // possible.
     var encrypted = _secureFilter.buffers[READ_ENCRYPTED];
     var plaintext = _secureFilter.buffers[READ_PLAINTEXT];
     bool progress = true;
@@ skipping 111 matching lines @@
   void destroy();
   void handshake();
   void init();
   X509Certificate get peerCertificate;
   int processBuffer(int bufferIndex);
   void registerBadCertificateCallback(Function callback);
   void registerHandshakeCompleteCallback(Function handshakeCompleteHandler);
 
   List<_ExternalBuffer> get buffers;
 }