RxJava-何时使用带创建方法的可观察

Question

我在读一篇教程：

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

它特别关注RxAndroid，但它与RxJava中的几乎相同。我不确定我是否完全理解了这个概念。

下面我写了一个方法，然后是一个示例用法。

我的问题是：这是实现我的函数以便我可以在其他线程上异步运行它们的正确方法吗？事实上，它们只会返回一个创建的可观察的运行真实代码，并处理错误和所有这些东西。

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

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(...)

还有调度程序。immediate（）用于在当前线程上执行订阅服务器代码？它说“创建并返回一个调度器，该调度器在当前线程上立即执行工作。”在javadoc中，但我不确定。

Answer 1

但是，您可以通过Observable.create（新的OnSubscribe{}）方法创建可观察：

• 看看defer（）操作符，它允许您返回例如observate。just（）和Observable。错误（），因此您不需要直接联系订阅者
• 首选使用SyncOnSubscribe/AsyncOnSubscribe来处理背压

调度程序。immediate（）将在已经存在的线程上保持可观察的处理，因此在您的情况下，它将是一个调度程序。io线程

Answer 2

您几乎不应该使用create（），尤其是初学者。有更简单的方法来创建可观察对象，并且很难正确实现。

大多数情况下，您可以通过使用延迟（）轻松地四处走动。E、 g.在这种情况下，您应该：

Observable<String> googleSomething(String text) {
  return Observable.defer(new Func0<Observable<String>>() {
    @Override
    public Observable<String> call() {
      try {
        return Observable.just(fetchData(text));
      } catch (IOException e) {
        return Observable.error(e);
      }
    }
  });
}

如果您没有使用选中的异常，那么您甚至可以摆脱try-catch。RxJava将自动将任何RuntimeException转发到订阅者的onError（）部分。

Answer 3

除非您更有经验并且需要自定义运算符或想要桥接基于旧版addListener/Remote veListener的API，否则您不应该从create开始。StackOverflow上有几个问题，它使用了create并且是问题的根源。

我更喜欢fromCallable，它可以让您生成单个值或抛出异常，因此不需要那些冗长的延迟只是源。

Schedulers.immediate（）立即在调用者的线程上执行其任务，在您的示例中是io（）线程，而不是主线程。目前，不支持将计算移回Java主线程，因为它需要阻塞蹦床，而且通常是个坏主意。