Adapt streams for additional stackTrace argument.

sdk/lib/io/http_parser.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;
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static const HTTP = const [72, 84, 84, 80];
@@ skipping 108 matching lines @@
     } else {
       pause();
       subscription.resume();
       subscription.onData(controller.add);
       subscription.onDone(controller.close);
       subscription.onError(controller.addError);
     }
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
-                                       {void onError(error),
+                                       {Function onError,
                                         void onDone(),
                                         bool cancelOnError}) {
     return controller.stream.listen(
         onData,
         onError: onError,
         onDone: onDone,
         cancelOnError: cancelOnError);
   }
 
   void resume() {
@@ skipping 73 matching lines @@
           try {
             _socketSubscription.cancel();
           } catch (e) {
           }
         });
     _reset();
   }
 
 
   StreamSubscription<_HttpIncoming> listen(void onData(_HttpIncoming event),
-                                           {void onError(error),
+                                           {Function onError,
                                             void onDone(),
                                             bool cancelOnError}) {
     return _controller.stream.listen(onData,
                                      onError: onError,
                                      onDone: onDone,
                                      cancelOnError: cancelOnError);
   }
 
   Future<_HttpParser> addStream(Stream<List<int>> stream) {
     // Listen to the stream and handle data accordingly. When a
@@ skipping 530 matching lines @@
     } else {
       _state = _State.FAILURE;
       // Report the error through the error callback if any. Otherwise
       // throw the error.
       error(new HttpException(
                   "Connection closed before full body was received"));
     }
     _controller.close();
   }
 
-  void _onError(e) {
-    _controller.addError(e);
+  void _onError(e, [StackTrace stackTrace]) {
+    _controller.addError(e, stackTrace);
   }
 
   String get version {
     switch (_httpVersion) {
       case _HttpVersion.HTTP10:
         return "1.0";
       case _HttpVersion.HTTP11:
         return "1.1";
     }
     return null;
@@ skipping 196 matching lines @@
   _HttpHeaders _headers;
 
   // The current incoming connection.
   _HttpIncoming _incoming;
   StreamSubscription _socketSubscription;
   bool _paused = true;
   bool _bodyPaused = false;
   StreamController<_HttpIncoming> _controller;
   StreamController<List<int>> _bodyController;
 }