Rename unsubscribeOnError to cancelOnError.

runtime/bin/socket_patch.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.
 
 patch class RawServerSocket  {
   /* patch */ static Future<RawServerSocket> bind([String address = "127.0.0.1",
                                                    int port = 0,
                                                    int backlog = 0]) {
     return _RawServerSocket.bind(address, port, backlog);
   }
@@ skipping 432 matching lines @@
       error: (e) {
         _controller.addError(new AsyncError(e));
         _controller.close();
       }
     );
   }
 
   StreamSubscription<RawSocket> listen(void onData(RawSocket event),
                                        {void onError(AsyncError error),
                                         void onDone(),
-                                        bool unsubscribeOnError}) {
+                                        bool cancelOnError}) {
     return _controller.stream.listen(
         onData,
         onError: onError,
         onDone: onDone,
-        unsubscribeOnError: unsubscribeOnError);
+        cancelOnError: cancelOnError);
   }
 
   int get port => _socket.port;
 
   void close() => _socket.close();
 
   void _pause() {
     _socket.setListening(read: false, write: false);
   }
 
@@ skipping 61 matching lines @@
   factory _RawSocket._readPipe(int fd) {
     var native = new _NativeSocket.pipe();
     native.isClosedWrite = true;
     if (fd != null) _getStdioHandle(native, fd);
     return new _RawSocket(native);
   }
 
   StreamSubscription<RawSocketEvent> listen(void onData(RawSocketEvent event),
                                             {void onError(AsyncError error),
                                              void onDone(),
-                                             bool unsubscribeOnError}) {
+                                             bool cancelOnError}) {
     return _controller.stream.listen(
         onData,
         onError: onError,
         onDone: onDone,
-        unsubscribeOnError: unsubscribeOnError);
+        cancelOnError: cancelOnError);
   }
 
   int available() => _socket.available();
 
   List<int> read([int len]) => _socket.read(len);
 
   int write(List<int> buffer, [int offset, int count]) =>
       _socket.write(buffer, offset, count);
 
   void close() => _socket.close();
@@ skipping 68 matching lines @@
                                     int backlog) {
     return _RawServerSocket.bind(address, port, backlog)
         .then((socket) => new _ServerSocket(socket));
   }
 
   _ServerSocket(this._socket);
 
   StreamSubscription<Socket> listen(void onData(Socket event),
                                     {void onError(AsyncError error),
                                      void onDone(),
-                                     bool unsubscribeOnError}) {
+                                     bool cancelOnError}) {
     return _socket.map((rawSocket) => new _Socket(rawSocket)).listen(
         onData,
         onError: onError,
         onDone: onDone,
-        unsubscribeOnError: unsubscribeOnError);
+        cancelOnError: cancelOnError);
   }
 
   int get port => _socket.port;
 
   void close() => _socket.close();
 }
 
 
 patch class Socket {
   /* patch */ static Future<Socket> connect(String host, int port) {
@@ skipping 31 matching lines @@
             offset = 0;
             write();
           },
           onError: (error) {
             socket._consumerDone();
             done(error);
           },
           onDone: () {
             done();
           },
-          unsubscribeOnError: true);
+          cancelOnError: true);
     }
     return streamCompleter.future;
   }
 
   Future<Socket> close() {
     socket._consumerDone();
     return new Future.immediate(socket);
   }
 
   void write() {
@@ skipping 77 matching lines @@
 
   factory _Socket._readPipe([int fd]) {
     return new _Socket(new _RawSocket._readPipe(fd));
   }
 
   _NativeSocket get _nativeSocket => _raw._socket;
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(AsyncError error),
                                         void onDone(),
-                                        bool unsubscribeOnError}) {
+                                        bool cancelOnError}) {
     return _controller.stream.listen(
         onData,
         onError: onError,
         onDone: onDone,
-        unsubscribeOnError: unsubscribeOnError);
+        cancelOnError: cancelOnError);
   }
 
   Encoding get encoding => _sink.encoding;
 
   void set encoding(Encoding value) {
     _sink.encoding = value;
   }
 
   void write(Object obj) => _sink.write(obj);
 
@@ skipping 32 matching lines @@
   int get remotePort => _raw.remotePort;
 
   // Ensure a subscription on the raw socket. Both the stream and the
   // consumer needs a subscription as they share the error and done
   // events from the raw socket.
   void _ensureRawSocketSubscription() {
     if (_subscription == null && _raw != null) {
       _subscription = _raw.listen(_onData,
                                   onError: _onError,
                                   onDone: _onDone,
-                                  unsubscribeOnError: true);
+                                  cancelOnError: true);
     }
   }
 
   _closeRawSocket() {
     var tmp = _raw;
     _raw = null;
     _closed = true;
     tmp.close();
   }
 
@@ skipping 83 matching lines @@
     _raw.onBadCertificate = callback;
   }
 
   X509Certificate get peerCertificate {
     if (_raw == null) {
      throw new StateError("peerCertificate called on destroyed SecureSocket");
     }
     return _raw.peerCertificate;
   }
 }