runService method

void runService({ required Future<void> start(K key, DspReg disposers), required DspReg disposers, })

Implementation

void runService({
  required Future<void> Function(K key, DspReg disposers) start,
  required DspReg disposers,
}) {
  final running = <K, DspImpl>{};

  final processDisposers = DspImpl();
  processDiffs(
    added: (item) async {
      final itemDsp = DspImpl();
      running[item] = itemDsp;
      await start(item, itemDsp);
    },
    removed: (item) async {
      final itemDsp = running.remove(item)!;
      await itemDsp.dispose();
    },
    disposers: processDisposers,
  );

  disposers.add(() async {
    await processDisposers.dispose();
    await Future.wait(
      running.values.map(
        (e) => e.dispose(),
      ),
    );
  });
}