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();
}