subscribeToActive method

Implementation

@protected
Disposable subscribeToActive(Observer<T> observer) =>
    CollectionDisposable<Observer<T>>.forList(_observers, observer);