Jak uruchomić to oświadczenie za pomocą RxJava?

Question

Rx sposób robienia rzeczy może być bardzo skomplikowana i żaden z wielu powodów ... ale czuję, istnieją proste sposoby wykonywania prostych rzeczy z RX ...

Jak bym po prostu wykonać to oświadczenie w sprawie wątek tła i otrzymać odpowiedź na wątku interfejsu użytkownika?

Wszystkie funkcje tego obiektu należy uruchomić na wątku tła. Pobierz, wstaw, wyczyść i usuń.

String city = Paper.get("city"); 

Answer 1

Podstawowym obiektem w Rx jest Observable. Obiekt ten zazwyczaj owija obiekt OnSubscribe, który jest po prostu rozszerzeniem Action1, który przyjmuje jako parametr parametr Subscriber.

Co to wszystko oznacza, że ​​po prostu trzeba zdefiniować klasę, która otacza swoją rozmowę i przekazuje wynik do Subscriber:

public class RxPaperGet implements Observable.OnSubscribe<String> { 
    @Override 
    public void call(Subscriber<? super String> t1) { 
     try { 
      t1.onNext(Paper.get("city")); 
     } catch (Throwable t) { 
      t1.onError(t); 
      return; 
     } 
     t1.onCompleted(); 
    } 
} 

To jest prosty przykład. Teraz chcesz go zawijać, aby można było wywoływać dowolną funkcję, a nie tylko Paper.get("city"). Coś takiego jak https://github.com/ReactiveX/RxJavaAsyncUtil/blob/0.x/src/main/java/rx/util/async/operators/OperatorFromFunctionals.java#L44 robi to, pozwalając ci przekazać dowolne Callable.

Które w przypadku byłoby wdrożyć jako:

Observable<String> res = OperatorFromFunctionals.fromCallable(() -> Paper.get("city")); 

(W przypadku, gdy zastanawiasz się, to java8 lambdas wniesione do Androidem retrolambda niezły usunąć gadatliwość Rx).

Gdy już zauważysz, możesz zasubskrybować i uzyskać wyniki. Aby wykonać na tle i pobierać wyniki na wątku UI, zrobiłbyś:

res.subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 

AndroidSchedulers zapewnia rx-android.

Następnie można po prostu calledback z wynikiem:

.subscribe(city -> Log.d(TAG, city)); 

która zwraca subskrypcję, która jest przydatna, gdy trzeba ją anulować.

Ogólnie:

OperatorFromFunctionals.fromCallable(() -> Paper.get("city")) 
    .subscribeOn(Schedulers.io()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(city -> Log.d(TAG, city)); 

Answer 2

EDIT: To nie jest poprawne. Nie usuwa jednak odpowiedzi, aby zachować komentarze.

Bardzo prosty przykład:

@Override 
protected void onCreate(Bundle savedInstanceState) { 
    super.onCreate(savedInstanceState); 
    setContentView(R.layout.activity_main); 


    getPaper() 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Action1<String>() { 
       @Override 
       public void call(String s) { 
        Log.d("xxx", s); 
       } 
      }); 


} 

private Observable<String> getPaper() { 

    return Observable.just(Paper.get()); 
} 

gdzie Paper.get() jest długa operacja docierania że zwraca String. Sprawdź docs for Scheduler.

Nie zapomnij obserwować w głównym wątku, jeśli chcesz zmienić interfejs użytkownika po otrzymaniu wyniku operacji, w przeciwnym razie otrzymasz wyjątek dotyczący zmiany interfejsu użytkownika spoza wątku interfejsu użytkownika.