observeMetrics method
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);
}