Class ObservableTake.TakeObserver<T>