Adapt streams for additional stackTrace argument.

sdk/lib/_internal/pub/lib/src/safe_http_server.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.
 
 library pub.safe_http_server;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
@@ skipping 34 matching lines @@
   }
 
   Duration get idleTimeout => _inner.idleTimeout;
   set idleTimeout(Duration value) {
     _inner.idleTimeout = value;
   }
 
   HttpConnectionsInfo connectionsInfo() => _inner.connectionsInfo();
 
   StreamSubscription<HttpRequest> listen(void onData(HttpRequest value),
-      {void onError(error), void onDone(),
+      {Function onError, void onDone(),
       bool cancelOnError: false}) {
     var subscription;
     subscription = super.listen((request) {
       onData(new _HttpRequestWrapper(request));
-    }, onError: (error) {
+    }, onError: (error, [stackTrace]) {
       // Ignore socket error 104, which is caused by a request being cancelled
       // before it writes any headers. There's no reason to care about such
       // requests.
       if (error is SocketException && error.osError.errorCode == 104) return;
       // Ignore any parsing errors, which come from malformed requests.
       if (error is HttpException) return;
       // Manually handle cancelOnError so the above (ignored) errors don't
       // cause unsubscription.
       if (cancelOnError) subscription.cancel();
-      if (onError != null) onError(error);
+      if (onError != null) {
+        if (onError is ZoneBinaryCallback) {
+          onError(error, stackTrace);
+        } else {
+          onError(error);
+        }
+      }
     }, onDone: onDone);
     return subscription;
   }
 }
 
 /// A wrapper around [HttpRequest] for the sole purpose of swallowing errors on
 /// [HttpResponse.done].
 class _HttpRequestWrapper extends StreamView<List<int>> implements HttpRequest {
   final HttpRequest _inner;
   final HttpResponse response;
@@ skipping 70 matching lines @@
   void addError(error) => _inner.addError(error);
 
   Duration get deadline => _inner.deadline;
   set deadline(Duration value) {
     _inner.deadline = value;
   }
 
   Future redirect(Uri location, {int status: HttpStatus.MOVED_TEMPORARILY}) =>
       _inner.redirect(location, status: status);
 }