Support shelf 0.7.0.

lib/src/runner/browser/suite.dart

 // Copyright (c) 2015, 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.
 
 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';
 import '../runner_suite.dart';
 import 'iframe_test.dart';
 
 /// Loads a [RunnerSuite] for a browser.
 ///
 /// [channel] should connect to the iframe containing the suite, which should
 /// eventually emit a message containing the suite's test information.
@@ skipping 17 matching lines @@
   //
   // Start this canceled because we don't want it to start ticking until we get
   // some response from the iframe.
   var timer = new RestartableTimer(new Duration(seconds: 3), () {
     controller.setDebugging(true);
   })..cancel();
 
   // 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);
-    }
+  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;
-  }), channel.sink);
+      return message;
+    });
+  }));
 
   var response = await _getResponse(suiteChannel.stream)
       .timeout(new Duration(minutes: 1), onTimeout: () {
     suiteChannel.sink.close();
     throw new LoadException(
         path,
         "Timed out waiting for the test suite to connect.");
   });
 
   try {
@@ skipping 82 matching lines @@
 /// Returns `null` if [test] is `null`.
 Test _deserializeTest(MultiChannel suiteChannel, Map test,
     [StackTraceMapper mapper]) {
   if (test == null) return null;
 
   var metadata = new Metadata.deserialize(test['metadata']);
   var testChannel = suiteChannel.virtualChannel(test['channel']);
   return new IframeTest(test['name'], metadata, testChannel,
       mapper: mapper);
 }