subscribe method

Subscription<T> subscribe(Observer<T> observer)

添加观察者

Implementation

Subscription<T> subscribe(Observer<T> observer) {
  final res = _observers.add(observer);
  if (res && observerCount == 1) {
    onActive();
  }
  return _Subscription<T>(this, observer);
}