Use stream_channel.

lib/src/barback/web_socket_api.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:io';
 
 import 'package:http_parser/http_parser.dart';
 import 'package:path/path.dart' as path;
 import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;
 
 import '../exit_codes.dart' as exit_codes;
 import '../io.dart';
 import '../log.dart' as log;
 import '../utils.dart';
 import 'asset_environment.dart';
 
 /// Implements the [WebSocket] API for communicating with a running pub serve
 /// process, mainly for use by the Editor.
 ///
 /// This is a [JSON-RPC 2.0](http://www.jsonrpc.org/specification) server. Its
 /// methods are described in the method-level documentation below.
 class WebSocketApi {
   final AssetEnvironment _environment;
   final json_rpc.Server _server;
 
   /// Whether the application should exit when this connection closes.
   bool _exitOnClose = false;
 
-  WebSocketApi(CompatibleWebSocket socket, this._environment)
+  WebSocketApi(WebSocketChannel socket, this._environment)
       : _server = new json_rpc.Server(socket) {
     _server.registerMethod("urlToAssetId", _urlToAssetId);
     _server.registerMethod("pathToUrls", _pathToUrls);
     _server.registerMethod("serveDirectory", _serveDirectory);
     _server.registerMethod("unserveDirectory", _unserveDirectory);
 
     /// Tells the server to exit as soon as this WebSocket connection is closed.
     ///
     /// This takes no arguments and returns no results. It can safely be called
     /// as a JSON-RPC notification.
@@ skipping 257 matching lines @@
 }
 
 /// The pub-specific JSON RPC error codes.
 class _Error {
   /// The specified directory is not being served.
   static const NOT_SERVED = 1;
 
   /// The specified directory overlaps one or more ones already being served.
   static const OVERLAPPING = 2;
 }