Class ObservablePublish.PublishConnection<T>