Changes Rx implementation using Observable.create and ReplaySubject