RxJava – 何时使用带有create方法的Observable

http://code.tutsplus.com/tutorials/getting-started-with-reactivex-on-android–cms-24387

特别是RxAndroid,但它和RxJava几乎相同.我不确定我完全理解这个概念.

下面我写了一个方法,然后是一个示例用法.

我的问题是：这是实现我的函数的正确方法,以便我可以异步地在其他线程上运行它们吗？实际上,它们只会返回一个运行真实代码的已创建的Observable,并处理错误和所有这些内容.

或者这是错的,那么我想知道正确的方法.

Observable<String> googleSomething(String text){
    return Observable.create(new Observable(){
        @Override
        public void call(Subscriber<? super String> subscriber) {
             try {
                String data = fetchData(text); // some normal method
                subscriber.onNext(data); // Emit the contents of the URL
                subscriber.onCompleted(); // Nothing more to emit
            } catch(Exception e) {
                subscriber.onError(e); // In case there are network errors
            }
        }
    });
}

googleSomething("hello world").subscribeOn(Schedulers.io()).observeOn(Schedulers.immediate()).subscribe(...)

还使用Schedulers.immediate()来执行当前线程上的订户代码？它说“创建并返回一个在当前线程上立即执行工作的调度程序.”在javadoc,但我不确定.