Use StreamChannel.

test/server/utils.dart

 // Copyright (c) 2014, 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 'dart:convert';
 
+import 'package:stream_channel/stream_channel.dart';
+import 'package:test/test.dart';
+
 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;
 import 'package:json_rpc_2/error_code.dart' as error_code;
-import 'package:test/test.dart';
 
 /// A controller used to test a [json_rpc.Server].
 class ServerController {
   /// The controller for the server's request stream.
   final _requestController = new StreamController<String>();
 
   /// The controller for the server's response sink.
   final _responseController = new StreamController<String>();
 
   /// The server.
   json_rpc.Server get server => _server;
   json_rpc.Server _server;
 
   ServerController() {
     _server = new json_rpc.Server(
-        _requestController.stream, _responseController.sink);
+        new StreamChannel(_requestController.stream, _responseController.sink));
     _server.listen();
   }
 
   /// Passes [request], a decoded request, to [server] and returns its decoded
   /// response.
   Future handleRequest(request) =>
       handleJsonRequest(JSON.encode(request)).then(JSON.decode);
 
   /// Passes [request], a JSON-encoded request, to [server] and returns its
   /// encoded response.
@@ skipping 51 matching lines @@
 /// times. By default, this should pump the event queue enough times to allow
 /// any code to run, as long as it's not waiting on some external event.
 Future pumpEventQueue([int times = 20]) {
   if (times == 0) return new Future.value();
   // We use a delayed future to allow microtask events to finish. The
   // Future.value or Future() constructors use scheduleMicrotask themselves and
   // would therefore not wait for microtask callbacks that are scheduled after
   // invoking this method.
   return new Future.delayed(Duration.ZERO, () => pumpEventQueue(times - 1));
 }