LatestExecutor<T extends Object> constructor

LatestExecutor<T extends Object>({ required Future<void> process(T value), required DspReg disposers, })

Implementation

LatestExecutor({
  required this.process,
  required DspReg disposers,
}) : _disposers = disposers {
  disposers.add(() async {
    await _working?.future;
  });
}