9

我的理解是 rxjava-android 在单独的线程上执行操作（当提供正确的调度程序时），导致非阻塞操作，但是快速而肮脏的测试似乎证明这是不正确的。

我使用了以下代码片段，在这两种情况下，UI 都被阻止了......

片段 1

Observable observable = Observable.create(new Observable.OnSubscribe<Object>() {
  @Override
  public void call(Subscriber<? super Object> subscriber) {
    int i = 0;
    while (i == 0) {}
    subscriber.onCompleted();
  }
});
observable.subscribeOn(Schedulers.newThread());
observable.observeOn(AndroidSchedulers.mainThread());
observable.subscribe();

片段 2

Observable observable = Observable.create(new Observable.OnSubscribe<Object>() {
  @Override
  public void call(Subscriber<? super Object> subscriber) {
    SystemClock.sleep(5000);
    subscriber.onCompleted();
  }
});
observable.subscribeOn(Schedulers.newThread());
observable.observeOn(AndroidSchedulers.mainThread());
observable.subscribe();

我在这里错过了什么吗？

4

1 回答 1

29

错误是你用错了Observable。正确的代码应该是：

Observable observable = Observable.create(new Observable.OnSubscribe<Object>() {
  @Override
  public void call(Subscriber<? super Object> subscriber) {
    int i = 0;
    while (i == 0) {}
    subscriber.onCompleted();
  }
});
observable.subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()).subscribe();

两者都subscribeOn返回observeOn一个新的 Observable 来实现它们的功能。但是原始的 Observable 没有被修改。实际上，每个操作员都会创建一个新的 Observable 而不会修改原来的 Observable。

于 2014-05-04T02:45:29.963 回答