Implement ColdObservable