doShutdown method

@protected @override Future doShutdown()

Implementation

@protected
@override
Future doShutdown() async {
  for (final e in _recordStreams.entries) {
    await e.value.dispose();
  }
  _allChangeStream.close();
}