observeMetrics method

Future<Stream<TransactionMetricsDoc>> observeMetrics({
  1. required String operator,
  2. required List<String> accounts,
  3. Int64? startingFrom,
})

Implementation

Future<Stream<TransactionMetricsDoc>> observeMetrics({
  required String operator,
  required List<String> accounts,
  Int64? startingFrom,
}) async {
  final request = ObserveAccountsRequest();
  request.involvedAccounts.addAll(accounts.map((a) => hex.decode(a)));

  if (startingFrom != null) {
    request.startingFrom = TxId()..txId = startingFrom;
  }

  final envelop = await requestEnvelope(request: request);
  final stream = getServiceClient(operator).query.observeMetrics(envelop);
  return stream.map(TransactionMetricsDoc.fromModel);
}