Fix problem with Observable.create()