Rename unsubscribeOnError to cancelOnError.

sdk/lib/io/websocket_impl.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;
 
 const String _webSocketGUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
 
 class _WebSocketMessageType {
   static const int NONE = 0;
@@ skipping 19 matching lines @@
   static const int RESERVED_D = 13;
   static const int RESERVED_E = 14;
   static const int RESERVED_F = 15;
 }
 
 /**
  * The web socket protocol transformer handles the protocol byte stream
  * which is supplied through the [:handleData:]. As the protocol is processed,
  * it'll output frame data as either a List<int> or String.
  *
- * Important infomation about usage: Be sure you use unsubscribeOnError, so the
+ * Important infomation about usage: Be sure you use cancelOnError, so the
  * socket will be closed when the processer encounter an error. Not using it
  * will lead to undefined behaviour.
  */
 class _WebSocketProtocolTransformer extends StreamEventTransformer {
   static const int START = 0;
   static const int LEN_FIRST = 1;
   static const int LEN_REST = 2;
   static const int MASK = 3;
   static const int PAYLOAD = 4;
   static const int CLOSED = 5;
@@ skipping 489 matching lines @@
             } else {
               _close();
             }
             _readyState = WebSocket.CLOSED;
           }
           _closeCode = transformer.closeCode;
           _closeReason = transformer.closeReason;
           _controller.close();
           if (_writeClosed) _socket.destroy();
         },
-        unsubscribeOnError: true);
+        cancelOnError: true);
 
     _socket.done
         .catchError((error) {
           if (closed) return;
           closed = true;
           _readyState = WebSocket.CLOSED;
           _closeCode = WebSocketStatus.ABNORMAL_CLOSURE;
           _controller.addError(error);
           _controller.close();
         })
         .whenComplete(() {
           _writeClosed = true;
         });
   }
 
   StreamSubscription listen(void onData(message),
                             {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 readyState => _readyState;
 
   String get extensions => null;
   String get protocol => null;
   int get closeCode => _closeCode;
   String get closeReason => _closeReason;
 
   void close([int code, String reason]) {
@@ skipping 103 matching lines @@
       if (data != null) {
         _socket.add(data);
       }
     } catch (_) {
       // The socket can be closed before _socket.done have a chance
       // to complete.
       _writeClosed = true;
     }
   }
 }