Rename unsubscribeOnError to cancelOnError.

sdk/lib/io/http_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;
 
 class _HttpIncoming extends Stream<List<int>> {
   final int _transferLength;
   final Completer _dataCompleter = new Completer();
   Stream<List<int>> _stream;
@@ skipping 19 matching lines @@
   int get transferLength => _transferLength;
 
   _HttpIncoming(_HttpHeaders this.headers,
                 int this._transferLength,
                 Stream<List<int>> this._stream) {
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(AsyncError error),
                                         void onDone(),
-                                        bool unsubscribeOnError}) {
+                                        bool cancelOnError}) {
     return _stream.listen(onData,
                           onError: onError,
                           onDone: onDone,
-                          unsubscribeOnError: unsubscribeOnError);
+                          cancelOnError: cancelOnError);
   }
 
   // Is completed once all data have been received.
   Future get dataDone => _dataCompleter.future;
 
   void close() {
     fullBodyRead = true;
     _dataCompleter.complete();
   }
 }
@@ skipping 46 matching lines @@
           _session._markSeen();
           break;
         }
       }
     }
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(AsyncError error),
                                         void onDone(),
-                                        bool unsubscribeOnError}) {
+                                        bool cancelOnError}) {
     return _incoming.listen(onData,
                             onError: onError,
                             onDone: onDone,
-                            unsubscribeOnError: unsubscribeOnError);
+                            cancelOnError: cancelOnError);
   }
 
   Map<String, String> get queryParameters {
     if (_queryParameters == null) {
       _queryParameters = _HttpUtils.splitQueryString(uri.query);
     }
     return _queryParameters;
   }
 
   Uri get uri => _incoming.uri;
@@ skipping 100 matching lines @@
           request._responseRedirects.add(new _RedirectInfo(statusCode,
                                                            method,
                                                            url));
           return request.close();
         });
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(AsyncError error),
                                         void onDone(),
-                                        bool unsubscribeOnError}) {
+                                        bool cancelOnError}) {
     var stream = _incoming;
     if (headers.value(HttpHeaders.CONTENT_ENCODING) == "gzip") {
       stream = stream.transform(new ZLibInflater());
     }
     return stream.listen(onData,
                          onError: onError,
                          onDone: onDone,
-                         unsubscribeOnError: unsubscribeOnError);
+                         cancelOnError: cancelOnError);
   }
 
   Future<Socket> detachSocket() {
     _httpClient._connectionClosed(_httpRequest._httpClientConnection);
     return _httpRequest._httpClientConnection.detachSocket();
   }
 
   HttpConnectionInfo get connectionInfo => _httpRequest.connectionInfo;
 
   bool get _shouldAuthenticateProxy {
@@ skipping 324 matching lines @@
     _subscription = stream.listen(
         (data) {
           _controller.add(data);
         },
         onDone: () {
           _done();
         },
         onError: (error) {
           _done(error);
         },
-        unsubscribeOnError: true);
+        cancelOnError: true);
     return _completer.future;
   }
 
   Future close() {
     Future closeOutbound() {
       return _outbound._close().then((_) => _outbound);
     }
     if (_controller == null) return closeOutbound();
     _controller.close();
     return _closeCompleter.future.then((_) => closeOutbound());
@@ skipping 987 matching lines @@
   }
 
   _HttpServer._(this._serverSocket, this._closeServer);
 
   _HttpServer.listenOn(ServerSocket this._serverSocket)
       : _closeServer = false;
 
   StreamSubscription<HttpRequest> listen(void onData(HttpRequest event),
                                          {void onError(AsyncError error),
                                          void onDone(),
-                                         bool unsubscribeOnError}) {
+                                         bool cancelOnError}) {
     _serverSocket.listen(
         (Socket socket) {
           socket.setOption(SocketOption.TCP_NODELAY, true);
           // Accept the client connection.
           _HttpConnection connection = new _HttpConnection(socket, this);
           _connections.add(connection);
         },
         onError: _controller.addError,
         onDone: _controller.close);
     return _controller.stream.listen(onData,
                                      onError: onError,
                                      onDone: onDone,
-                                     unsubscribeOnError: unsubscribeOnError);
+                                     cancelOnError: cancelOnError);
   }
 
   void close() {
     closed = true;
     if (_serverSocket != null && _closeServer) {
       _serverSocket.close();
     }
     if (_sessionManagerInstance != null) {
       _sessionManagerInstance.close();
       _sessionManagerInstance = null;
@@ skipping 169 matching lines @@
 
 class _DetachedSocket extends Stream<List<int>> implements Socket {
   final Stream<List<int>> _incoming;
   final Socket _socket;
 
   _DetachedSocket(this._socket, this._incoming);
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(AsyncError error),
                                         void onDone(),
-                                        bool unsubscribeOnError}) {
+                                        bool cancelOnError}) {
     return _incoming.listen(onData,
                             onError: onError,
                             onDone: onDone,
-                            unsubscribeOnError: unsubscribeOnError);
+                            cancelOnError: cancelOnError);
   }
 
   Encoding get encoding => _socket.encoding;
 
   void set encoding(Encoding value) {
     _socket.encoding = value;
   }
 
   void write(Object obj) => _socket.write(obj);
 
@@ skipping 171 matching lines @@
 
 
 class _RedirectInfo implements RedirectInfo {
   const _RedirectInfo(int this.statusCode,
                       String this.method,
                       Uri this.location);
   final int statusCode;
   final String method;
   final Uri location;
 }