send method

@override Future<RpcResponse> send(String method, List params)

Send arbitrary message to RPC node

Implementation

@override
Future<RpcResponse> send(String method, List<dynamic> params) async {
  if (socket == null) {
    throw Exception('WebsocketChannel is closed');
  }
  await isReady();

  final id = _sequence++;
  final completer = Completer<RpcResponse>();
  final message = jsonEncode({
    'id': id,
    'jsonrpc': '2.0',
    'method': method,
    'params': params,
  });

  queries[id] = PendingQuery(message: message, completer: completer);
  socket!.send(message);

  return completer.future;
}