close method

Future<void> close()

Stops watching and ends the stream.

Implementation

Future<void> close() async {
  _documents.clear();
  final subscriptions = List.of(_subscriptions.values);
  _subscriptions.clear();
  for (final subscription in subscriptions) {
    await subscription.cancel();
  }
  await _controller.close();
}