Adapt streams for additional stackTrace argument.

pkg/barback/lib/src/utils.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 barback.utils;
 
 import 'dart:async';
 
 /// A pair of values.
 class Pair<E, F> {
@@ skipping 121 matching lines @@
   // Use a sync stream to preserve the synchrony behavior of the input streams.
   // If the inputs are sync, then this will be sync as well; if the inputs are
   // async, then the events we receive will also be async, and forwarding them
   // sync won't change that.
   var controller = broadcast ? new StreamController.broadcast(sync: true)
       : new StreamController(sync: true);
 
   for (var stream in streams) {
     stream.listen((value) {
       controller.add(value);
-    }, onError: (error) {
-      controller.addError(error);
-    }, onDone: () {
+    },

[Lasse Reichstein Nielsen, 2013/10/04 08:45:17]

just "controller.add", no need to eta-expand.

[floitsch, 2013/10/05 18:11:48]

Done.

+    onError: controller.addError,

[Lasse Reichstein Nielsen, 2013/10/04 08:45:17]

Is indentation right here. I'd like it to be indented by at least two.
Maybe:
 stream.listen(
   controller.add,
   onError: controller.addError,
   onDone: () {
     ...  
   }
 );

[floitsch, 2013/10/05 18:11:48]

Done.

+    onDone: () {
       doneCount++;
       if (doneCount == streams.length) controller.close();
     });
   }
 
   return controller.stream;
 }
 
 /// Prepends each line in [text] with [prefix]. If [firstPrefix] is passed, the
 /// first line is prefixed with that instead.
@@ skipping 26 matching lines @@
 Future newFuture(callback()) => new Future.value().then((_) => callback());
 
 /// Returns a buffered stream that will emit the same values as the stream
 /// returned by [future] once [future] completes. If [future] completes to an
 /// error, the return value will emit that error and then close.
 Stream futureStream(Future<Stream> future) {
   var controller = new StreamController(sync: true);
   future.then((stream) {
     stream.listen(
         controller.add,
-        onError: (error) => controller.addError(error),
+        onError: controller.addError,
         onDone: controller.close);
-  }).catchError((e) {
-    controller.addError(e);
+  }).catchError((e, StackTrace stackTrace) {
+    controller.addError(e, stackTrace);
     controller.close();
   });
   return controller.stream;
 }