У меня есть следующий способ отправки ответа на пользовательский интерфейс с помощью otto и 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();
}
Мне нужна помощь для преобразования этого AsyncTask в RxJava с помощью библиотеки RxAndroid.
Не используйте .create(), но используйте .defer()
Observable<File> observable = Observable.defer(new Func0<Observable<File>>() {
@Override public Observable<File> call() {
File file = downloadFile();
return Observable.just(file);
}
});
чтобы узнать подробности, см. https://speakerdeck.com/dlew/common-rxjava-mistakes
Это пример задачи загрузки файлов с использованием 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();
}
});
}
Использование:
downloadFileObservable()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(observer); // you can post your event to Otto here
Это будет загружать файл в новый поток и уведомлять вас в основном потоке.
OnSubscribeFunc устарел. Код обновлен, чтобы использовать OnSubscribe insted. Для получения дополнительной информации см. вопрос 802 на Github.
В вашем случае вы можете использовать fromCallable. Меньше кода и автоматические выбросы onError.
Observable<File> observable = Observable.fromCallable(new Callable<File>() {
@Override
public File call() throws Exception {
File file = downloadFile();
return file;
}
});
Использование lambdas:
Observable<File> observable = Observable.fromCallable(() -> downloadFile());