close method

void close()
override

Closes the stream

Implementation

void close() {
  _subscriptions.forEach((observable, subscription) {
    subscription.cancel();
  });
  _subscriptions.clear();
  subject.close();
}