Instrument communications

pkg/analysis_server/test/channel/web_socket_channel_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.
 
 library test.channel.web_socket;
 
 import 'dart:async';
 
 import 'package:analysis_server/src/channel/web_socket_channel.dart';
 import 'package:analysis_server/src/protocol.dart';
+import 'package:analyzer/instrumentation/instrumentation.dart';
 import 'package:unittest/unittest.dart';
 
 import '../mocks.dart';
 
 main() {
   group('WebSocketChannel', () {
     setUp(WebSocketChannelTest.setUp);
     test('close', WebSocketChannelTest.close);
     test('invalidJsonToClient', WebSocketChannelTest.invalidJsonToClient);
     test('invalidJsonToServer', WebSocketChannelTest.invalidJsonToServer);
@@ skipping 110 matching lines @@
     return client.responseStream.first.timeout(
         new Duration(seconds: 1)).then((Response response) {
       expect(response.id, equals('myId'));
       expectMsgCount(responseCount: 1);
     });
   }
 
   static void setUp() {
     socket = new MockSocket.pair();
     client = new WebSocketClientChannel(socket);
-    server = new WebSocketServerChannel(socket.twin);
+    server =
+        new WebSocketServerChannel(socket.twin, new NullInstrumentationServer());
 
     requestsReceived = [];
     responsesReceived = [];
     notificationsReceived = [];
 
     // Allow multiple listeners on server side for testing.
     socket.twin.allowMultipleListeners();
 
     server.listen(requestsReceived.add);
     client.responseStream.listen(responsesReceived.add);
     client.notificationStream.listen(notificationsReceived.add);
   }
 }