Android RxJava, bez blokowania?

Question

To było moje zrozumienie, że rxjava-android wykonuje operacje na osobnym wątku (pod warunkiem, że jest to poprawny Scheduler), co prowadzi do operacji nieblokujących, jednak szybki i brudny test zdaje się potwierdzać, że jest to nieprawidłowe.

użyłem następujące fragmenty kodu, a w obu scenariuszach, interfejs użytkownika był blokowany ...

urywek 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(); 

Snippet 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(); 

Czy coś mi umyka?

Answer 1

Błąd polega na tym, że używasz niewłaściwego Observable. Poprawny kod powinien być:

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

Zarówno subscribeOn i observeOn powrócić nowy Obserwowalne który realizuje swoje funkcje. Ale oryginalna obserwowalna nie jest modyfikowana. W rzeczywistości każdy operator zawsze tworzy nowy Observable bez modyfikowania oryginału.