Update reactor.createObservable to be consisten with Observable.compose