close method
void
close()
Closes the subscriptions for this Rx, releasing the resources.
Implementation
void close() {
_subscriptions.forEach((getStream, subscriptions) {
for (final subscription in subscriptions) {
subscription.cancel();
}
});
_subscriptions.clear();
subject.close();
}