close method

FutureOr<void> close()

Closes the subscriptions for this Rx, releasing the resources.

Implementation

FutureOr<void> close() async {
  for (final e in _subscriptions.values) {
    for (final subs in e) {
      await subs.cancel();
    }
  }
  _subscriptions.clear();
  return subject.close();
}