| Index: lib/src/runner/browser/suite.dart
|
| diff --git a/lib/src/runner/browser/suite.dart b/lib/src/runner/browser/suite.dart
|
| index a0c9e3ab3eaf73f474ffd4cc2be8e8c191bbc845..0e8d3c3e71511faaaf55582dd9f122d6a3c724da 100644
|
| --- a/lib/src/runner/browser/suite.dart
|
| +++ b/lib/src/runner/browser/suite.dart
|
| @@ -5,15 +5,14 @@
|
| import 'dart:async';
|
|
|
| import 'package:async/async.dart';
|
| +import 'package:stream_channel/stream_channel.dart';
|
|
|
| import '../../backend/group.dart';
|
| import '../../backend/metadata.dart';
|
| import '../../backend/test.dart';
|
| import '../../backend/test_platform.dart';
|
| -import '../../util/multi_channel.dart';
|
| import '../../util/remote_exception.dart';
|
| import '../../util/stack_trace_mapper.dart';
|
| -import '../../util/stream_channel.dart';
|
| import '../../utils.dart';
|
| import '../environment.dart';
|
| import '../load_exception.dart';
|
| @@ -51,16 +50,18 @@ Future<RunnerSuite> loadBrowserSuite(StreamChannel channel,
|
| // Even though [channel] is probably a [MultiChannel] already, create a
|
| // nested MultiChannel because the iframe will be using a channel wrapped
|
| // within the host's channel.
|
| - var suiteChannel = new MultiChannel(channel.stream.map((message) {
|
| - // Whenever we get a message, no matter which child channel it's for, we the
|
| - // browser is still running code which means the using isn't debugging.
|
| - if (controller != null) {
|
| - timer.reset();
|
| - controller.setDebugging(false);
|
| - }
|
| -
|
| - return message;
|
| - }), channel.sink);
|
| + var suiteChannel = new MultiChannel(channel.changeStream((stream) {
|
| + return stream.map((message) {
|
| + // Whenever we get a message, no matter which child channel it's for, we the
|
| + // browser is still running code which means the using isn't debugging.
|
| + if (controller != null) {
|
| + timer.reset();
|
| + controller.setDebugging(false);
|
| + }
|
| +
|
| + return message;
|
| + });
|
| + }));
|
|
|
| var response = await _getResponse(suiteChannel.stream)
|
| .timeout(new Duration(minutes: 1), onTimeout: () {
|
|
|