这是我的理解是,在一个单独的线程(如果提供了正确的调度程序),从而导致非阻塞操作rxjava-机器人进行操作,但一个快速和肮脏的测试,似乎证明了这是不正确的。
It was my understanding that rxjava-android performs operations on a separate thread (when provided the correct Scheduler), leading to non-blocking operations, however a quick and dirty test seems to prove this to be incorrect.
我用下面的code片段,并在两者情况下,用户界面是被封锁...
I used the following code snippets and in both, scenarios, the UI was being blocked...
片段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();
我失去了一些东西呢?
Am I missing something here?
这个错误是,你用错了观测
。正确的code应该是:
The mistake is that you use the wrong Observable
. The correct code should be:
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
返回一个新的观测它实现其功能。但是原始观测不会被修改。实际上,各运营商总是会创建一个新的观测,而无需修改原来的。
Both subscribeOn
and observeOn
return a new Observable which implements their functions. But the original Observable is not modified. Actually, every operator will always create a new Observable without modifying the original one.