observeTransfers method
Implementation
Future<Stream<List<TransferResultDoc>>> observeTransfers({
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.observeTransfers(envelop);
return stream.map(
(transactions) =>
transactions.transactions.map(TransferResultDoc.fromModel).toList(),
);
}