listCompensations method

  1. @override
Future<List<WorkflowJournalEntry>> listCompensations(
  1. String runId
)
override

Lists compensation records in descending successful completion order.

Implementation

@override
Future<List<WorkflowJournalEntry>> listCompensations(String runId) async {
  final entries =
      (_journal[runId]?.values
                .where(
                  (entry) => entry.kind == WorkflowJournalKind.compensation,
                )
                .toList() ??
            <WorkflowJournalEntry>[])
        ..sort((a, b) => b.position!.compareTo(a.position!));
  return List.unmodifiable(entries);
}