Class ObservablePublishSelector.SourceObserver<T>