Pracuję nad siecią dla mojej aplikacji. Postanowiłem więc wypróbować Square's Retrofit . Widzę, że obsługują prosteCallback
@GET("/user/{id}/photo")
void getUserPhoto(@Path("id") int id, Callback<Photo> cb);
i RxJava Observable
@GET("/user/{id}/photo")
Observable<Photo> getUserPhoto(@Path("id") int id);
Oba wyglądają dość podobnie na pierwszy rzut oka, ale kiedy dochodzi do implementacji, robi się interesująco ...
Podczas gdy z prostą implementacją wywołania zwrotnego wyglądałoby podobnie do tego:
api.getUserPhoto(photoId, new Callback<Photo>() {
@Override
public void onSuccess() {
}
});
co jest dość proste i jednoznaczne. A dzięki Observable
temu szybko staje się gadatliwy i dość skomplikowany.
public Observable<Photo> getUserPhoto(final int photoId) {
return Observable.create(new Observable.OnSubscribeFunc<Photo>() {
@Override
public Subscription onSubscribe(Observer<? super Photo> observer) {
try {
observer.onNext(api.getUserPhoto(photoId));
observer.onCompleted();
} catch (Exception e) {
observer.onError(e);
}
return Subscriptions.empty();
}
}).subscribeOn(Schedulers.threadPoolForIO());
}
I to nie wszystko. Nadal musisz zrobić coś takiego:
Observable.from(photoIdArray)
.mapMany(new Func1<String, Observable<Photo>>() {
@Override
public Observable<Photo> call(Integer s) {
return getUserPhoto(s);
}
})
.subscribeOn(Schedulers.threadPoolForIO())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Photo>() {
@Override
public void call(Photo photo) {
//save photo?
}
});
Czy coś mi umyka? Czy jest to niewłaściwy przypadek użycia Observable
s? Kiedy należy / należy preferować Observable
proste wywołanie zwrotne?
Aktualizacja
Korzystanie z modernizacji jest znacznie prostsze niż powyższy przykład, jak pokazał @Niels w swojej odpowiedzi lub w przykładowym projekcie Jake'a Whartona U2020 . Ale w gruncie rzeczy pytanie pozostaje takie samo - kiedy należy użyć jednego lub drugiego sposobu?