processDiffs method

void processDiffs({ required Future<void> added(T item), required Future<void> removed(T item), required DspReg disposers, })

Implementation

void processDiffs({
  required Future<void> Function(T item) added,
  required Future<void> Function(T item) removed,
  required DspReg disposers,
}) async {
  final listening = diffs.asyncListen((diff) async {
    await Future.wait([
      ...diff.added.map(added),
      ...diff.removed.map(removed),
    ]);
  });

  disposers.add(listening.cancel);
}