close method

  1. @override
void close()
override

Closes the stream

Implementation

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