close method

void close()

Implementation

void close() {
  _subscriptions.forEach((_notifier, _subscriptions) {
    for (BtSubscription<T> sub in _subscriptions) {
      // just remove subscription from notifier, do not close the notifier, cause notifier maybe bind with other observer
      // notifier and observer are in a Many-to-many relationships
      _notifier.eliminate(sub);
    }
  });
  _subscriptions.clear();
  _stream.close();
}