Use StreamChannel.

test/peer_test.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/error_code.dart' as error_code;
 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;
 
 void main() {
   var incoming;
   var outgoing;
   var peer;
   setUp(() {
     var incomingController = new StreamController();
     incoming = incomingController.sink;
     var outgoingController = new StreamController();
     outgoing = outgoingController.stream;
     peer = new json_rpc.Peer.withoutJson(
-        incomingController.stream, outgoingController);
+        new StreamChannel(incomingController.stream, outgoingController));
   });
 
   group("like a client,", () {
     test("can send a message and receive a response", () {
       expect(outgoing.first.then((request) {
         expect(request, equals({
           "jsonrpc": "2.0",
           "method": "foo",
           "params": {"bar": "baz"},
           "id": 0
@@ skipping 125 matching lines @@
           "params": {"x": "y"},
           "id": 2
         }
       ]);
     });
 
     test("returns a response for malformed JSON", () {
       var incomingController = new StreamController();
       var outgoingController = new StreamController();
       var jsonPeer = new json_rpc.Peer(
-          incomingController.stream, outgoingController);
+          new StreamChannel(incomingController.stream, outgoingController));
 
       expect(outgoingController.stream.first.then(JSON.decode), completion({
         "jsonrpc": "2.0",
         "error": {
           'code': error_code.PARSE_ERROR,
           "message": startsWith("Invalid JSON: "),
           "data": {'request': '{invalid'}
         },
         "id": null
       }));
@@ skipping 15 matching lines @@
       }));
 
       peer.listen();
 
       incoming.add({
         "completely": "wrong"
       });
     });
   });
 }