TaskQueue constructor

TaskQueue({ required DspReg disposers, })

Implementation

TaskQueue({
  required DspReg disposers,
}) : _disposers = disposers {
  () async {
    await for (final task in _queue.stream) {
      await task();
    }
  }();
  _disposers.add(() async {
    await _queue.close();
  });
}