Konvertieren von AsyncTask zu RxAndroid

Question

Ich habe die folgende Methode, Antwort auf UI mit otto und AsyncTask zu buchen.

private static void onGetLatestStoryCollectionSuccess(final StoryCollection storyCollection, final Bus bus) { 
    new AsyncTask<Void, Void, Void>() { 
     @Override 
     protected Void doInBackground(Void... params) { 
      bus.post(new LatestStoryCollectionResponse(storyCollection)); 
      return null; 
     } 
    }.execute(); 
} 

Ich brauche Hilfe dieses AsyncTask-RxJava mit RxAndroid Bibliothek zu konvertieren.

Answer 1

Verwenden .Create nicht(), aber verwenden .defer()

Observable<File> observable = Observable.defer(new Func0<Observable<File>>() { 
    @Override public Observable<File> call() { 

    File file = downloadFile(); 

    return Observable.just(file); 
    } 
}); 

mehr Details wissen sehen https://speakerdeck.com/dlew/common-rxjava-mistakes

Answer 2

Dies ist ein Beispiel für ein Download-Task-Datei RxJava mit

Observable<File> downloadFileObservable() { 
    return Observable.create(new OnSubscribeFunc<File>() { 
     @Override 
     public Subscription onSubscribe(Observer<? super File> fileObserver) { 
      try { 
       byte[] fileContent = downloadFile(); 
       File file = writeToFile(fileContent); 
       fileObserver.onNext(file); 
       fileObserver.onCompleted(); 
      } catch (Exception e) { 
       fileObserver.onError(e); 
      } 
      return Subscriptions.empty(); 
     } 
    }); 
} 

Verbrauch:

downloadFileObservable() 
    .subscribeOn(Schedulers.newThread()) 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(observer); // you can post your event to Otto here 

Diese Datei auf einen neuen Thread downloaden würde und Sie auf dem Haupt-Thread mitteilen.

OnSubscribeFunc wurde veraltet. Code aktualisiert, um OnSubscribe zu verwenden. Für weitere Informationen siehe issue 802 on Github.

Code from here.

Answer 3

In Ihrem Fall können Sie Verwenden Sie fromCallable. Weniger Code und automatische onError Emissionen.

Observable<File> observable = Observable.fromCallable(new Callable<File>() { 
     @Override 
     public File call() throws Exception { 
      File file = downloadFile(); 
      return file; 
     } 
    }); 

Mit lambdas:

Observable<File> observable = Observable.fromCallable(() -> downloadFile());