Added ObservableGenerator to avoid Observable.Generator memory leak