Implemented IObservable<T> in the program