subscribeToActive method

  1. @protected
Disposable subscribeToActive(
  1. Observer<T> observer
)

Implementation

@protected
Disposable subscribeToActive(Observer<T> observer) {
  _observers.add(observer);
  return ActionDisposable(() => _observers.remove(observer));
}