close method

Future close()

Implementation

Future close() async {
  await Future.wait(_subs.map((s) => s.cancel()));
  _subs.clear();
  await _onChange.close();
}