anchor.diff:      });
     }
   
  -  /// Connect to '127.0.0.1' at [port].
  -  static Future<VMService> connect(Uri httpUri) async {
  +  /// Connect to a Dart VM Service at [httpUri].
  +  ///
  +  /// Requests made via the returns [VMService] time out after [requestTimeout]
  +  /// amount of time, which is [kDefaultRequestTimeout] by default.
  +  static Future<VMService> connect(Uri httpUri, {Duration requestTimeout: kDefaultRequestTimeout}) async {
       Uri wsUri = httpUri.replace(scheme: 'ws', path: path.join(httpUri.path, 'ws'));
       WebSocket ws;
       try {
  
positive.code: 
    /// Invoke the RPC and return the raw response.
    Future<Map<String, dynamic>> invokeRpcRaw(
        String method, [Map<String, dynamic> params]) async {
      if (params == null) {
        params = <String, dynamic>{};
      }
      Map<String, dynamic> result =
          await _vmService.peer.sendRequest(method, params);
      return result;
    }
  
    /// Invoke the RPC and return a ServiceObject response.
  
negative.code:       String method, [Map<String, dynamic> params]) async {
      try {
        return await invokeRpcRaw(method, params);
      } on rpc.RpcException catch (e) {
        // If an application is not using the framework
        if (e.code == rpc_error_code.METHOD_NOT_FOUND)
          return null;
        rethrow;
      }
  