Adapt streams for additional stackTrace argument.

pkg/barback/lib/src/stream_replayer.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.stream_replayer;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'utils.dart';
@@ skipping 16 matching lines @@
 
   /// The controllers that are listening for future events from [_stream].
   final _controllers = new Set<StreamController<T>>();
 
   StreamReplayer(this._stream) {
     _stream.listen((data) {
       _buffer.add(new Either<T, dynamic>.withFirst(data));
       for (var controller in _controllers) {
         controller.add(data);
       }
-    }, onError: (error) {
+    }, onError: (error, [StackTrace stackTrace]) {

[nweiz, 2013/10/07 18:49:51]

[_buffer] now needs to track the stack trace along with errors. It should
probably be an Either<T, Pair<dynamic, StackTrace>> now.

[floitsch, 2013/10/10 14:22:52]

Done.

       _buffer.add(new Either<T, dynamic>.withSecond(error));
       for (var controller in _controllers) {
-        controller.addError(error);
+        controller.addError(error, stackTrace);
       }
     }, onDone: () {
       _isClosed = true;
       for (var controller in _controllers) {
         controller.close();
       }
       _controllers.clear();
     });
   }
 
   /// Returns a stream that replays the values and errors of the input stream.
   ///
   /// This stream is a buffered stream regardless of whether the input stream
   /// was broadcast or buffered.
   Stream<T> getReplay() {
     var controller = new StreamController<T>();
     for (var eventOrError in _buffer) {
       eventOrError.match(controller.add, controller.addError);
     }
     if (_isClosed) {
       controller.close();
     } else {
       _controllers.add(controller);
     }
     return controller.stream;
   }
 }