Observatory now uses websockets to communicate with the vm.

runtime/bin/vmservice/server.dart

 // Copyright (c) 2013, 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.
 
 part of vmservice_io;
 
 class WebSocketClient extends Client {
   static const int PARSE_ERROR_CODE = 4000;
   static const int BINARY_MESSAGE_ERROR_CODE = 4001;
   static const int NOT_MAP_ERROR_CODE = 4002;
@@ skipping 11 matching lines @@
         map = JSON.decode(message);
       } catch (e) {
         socket.close(PARSE_ERROR_CODE, 'Message parse error: $e');
         return;
       }
       if (map is! Map) {
         socket.close(NOT_MAP_ERROR_CODE, 'Message must be a JSON map.');
         return;
       }
       var seq = map['seq'];
-      onMessage(seq, new Message.fromMap(map));
+      onMessage(seq, new Message.fromUri(Uri.parse(map['request'])));
     } else {
-      socket.close(BINARY_MESSAGE_ERROR_CODE, 'message must be a string.');
+      socket.close(BINARY_MESSAGE_ERROR_CODE, 'Message must be a string.');
     }
   }
 
   void post(var seq, String response) {
     try {
       Map map = {
         'seq': seq,
         'response': response
       };
       socket.add(JSON.encode(map));
@@ skipping 81 matching lines @@
       port = s.port;
       _server = s;
       _server.listen(_requestHandler);
       if (display_message) {
         print('Observatory listening on http://$ip:$port');
       }
       return s;
     });
   }
 }