Adapt streams for additional stackTrace argument.

pkg/scheduled_test/lib/src/schedule.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 schedule;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'package:stack_trace/stack_trace.dart';
@@ skipping 427 matching lines @@
     _schedule.heartbeat();
     return Future.forEach(_contents, (task) {
       _schedule._currentTask = task;
       if (_error != null) throw _error;
       if (_aborted) return;
 
       _taskFuture = new SubstituteFuture(task.fn());
       return _taskFuture.whenComplete(() {
         _taskFuture = null;
         _schedule.heartbeat();
-      }).catchError((e) {
-        var error = new ScheduleError.from(_schedule, e);
+      }).catchError((e, trace) {
+        var error = new ScheduleError.from(_schedule, e, stackTrace: trace);
         _signalError(error);
         throw _error;
       });
     }).whenComplete(() {
       _schedule._currentTask = null;
     }).then((_) {
       _onTasksCompleteCompleter.complete();
-    }).catchError((e) {
-      _onTasksCompleteCompleter.completeError(e);
+    }).catchError((e, stackTrace) {
+      _onTasksCompleteCompleter.completeError(e, stackTrace);
       throw e;
     }).whenComplete(() {
       if (pendingCallbacks.isEmpty) return;
-      return _noPendingCallbacks.catchError((e) {
+      return _noPendingCallbacks.catchError((e, stackTrace) {
         // Signal the error rather than passing it through directly so that if a
         // timeout happens after an in-task error, both are reported.
-        _signalError(new ScheduleError.from(_schedule, e));
+        _signalError(new ScheduleError.from(_schedule, e,
+                                            stackTrace: stackTrace));
       });
     }).whenComplete(() {
       _schedule.heartbeat();
       // If the tasks were otherwise successful, make sure we throw any
       // out-of-band errors. If a task failed, make sure we throw the most
       // recent error.
       if (_error != null) throw _error;
     });
   }
 
@@ skipping 129 matching lines @@
   /// The string description of the callback.
   String get description {
     if (_description == null) _description = _thunk();
     return _description;
   }
 
   String toString() => description;
 
   PendingCallback._(this._thunk);
 }