Converti AsyncTask in RxAndroid

Question

Ho il seguente metodo per inviare la risposta all'interfaccia utente utilizzando otto e AsyncTask.

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

ho bisogno di aiuto per convertire questo AsyncTask-RxJava utilizzando biblioteca RxAndroid.

Answer 1

Non utilizzare .create(), ma usano .defer()

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

    File file = downloadFile(); 

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

di conoscere maggiori dettagli si veda https://speakerdeck.com/dlew/common-rxjava-mistakes

Answer 2

Questo è un esempio per un compito download di file utilizzando RxJava

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

Usage:

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

Ciò scaricare il file su un nuovo thread e di notifica sul thread principale.

OnSubscribeFunc è stato dichiarato obsoleto. Codice aggiornato per utilizzare OnSubscribe insted. Per maggiori informazioni visita issue 802 on Github.

Code from here.

Answer 3

Nel tuo caso è possibile utilizzare fromCallable. Meno codice e emissioni automatiche onError.

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

Uso lambda:

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