Добрый день, у меня есть фрагмент, в него с помощью адаптера помещаются данные, изначально данные пусты и адаптер ничего не выводит, с помощью GET запроса библиотеки RETROFIT получаю json обьект, паршу его и вывожу в адаптер, но загрузка происходит в парралальном потоке, конечно раньше я просто вызывал adapter.notifyDatasetChanged() в onResponse() задания. Но теперь мне нужно загруженные объекты наполнить другими объектами через цикл и другой запрос
ApiInterface service = ApiModule.getClient();
Call<List<offerClass>> offerCall = service.getActiveSimpleOrder(1); // указываем id ресторана.
offerCall.enqueue(new Callback<List<offerClass>>() {
@Override
public void onResponse(Call<List<offerClass>> call, Response<List<offerClass>> response) {
offers.clear(); // Очистить контейнер перед наполнением.
try {
offers.addAll(response.body()); // Получили заказы
Log.i("Call","Request assigned");
} catch (Exception e) {
e.printStackTrace();
}
ApiInterface service = ApiModule.getClient();
for(final offerClass offer:offers) // Для каждого заказа ищем статус
{
Call<orderStatus> statusCall = service.getOrderStatus(Integer.parseInt(offer.getId()));
// Для каждого заказа получаем его статус.
statusCall.enqueue(new Callback<orderStatus>() {
@Override
public void onResponse(Call<orderStatus> call, Response<orderStatus> response) {
// если статус получен присваиваем его заказу
offer.setStatus(response.body());
}
@Override
public void onFailure(Call<orderStatus> call, Throwable t) {
}
});
Как видите загружается основной класс offers, и для каждого offer загружается его статус status через цикл. Как мне обновить адаптер в основном потоке, какое событие и как создать? когда я буду точно уверен что цикл отработал? потому что данный код вызовет в адаптере nullpointer exception, данные приходят по запросу, но я не уверен что код работает так как я думаю и хочу чтобы он работал.
Было решено разобраться с функционированием RX и типом данных Observable.
Отрывок из Rest API interface, сигнатура запросов.
@GET("orderStatus/{id}")
Observable<orderStatus> getOrderStatus(@Path("id") int id);
@GET("activeSimpleOrder/{id}")
Observable<List<offerClass>> getActiveSimpleOrder(@Path("id") int id);
Отрывок кода из основного потока фрагмента:
Observable<List<offerClass>> offercall =service.getActiveSimpleOrder(1);
Observable<orderStatus> statusCall = service.getOrderStatus(1);
Таким образом мы получаем лист offerClass содержащий объекты каждый со своим id с пустым orderStatus.
И потом получаем orderStatus для "1" id.
А вообще надо получить orderStatus для всего листа . подставляя в функцию id каждого offerClass.getId(). Таким образом получить "наполненный" класс. и после всего вызвать adapterNotifyDataSetChanged() в основном потоке, тем самым обработав событие.
как я понимаю должен быть создан обьект (в каком месте кода? в онкрейт фрагмента?)
Observable myObservable
с методом
@Override public void call
в котором скачать данные и заполнить класс offerClass обьектами класса orderStatus и вызвать myObsevable.onCompleted();
Потом создать (где? как?)
Subscriber<orderStatus> mySubscriber = new Subscriber<orderStatus>() {
@Override
public void onCompleted() { }
@Override
public void onError(Throwable e) { }
и соотвественно когда Observable закончит наполнение, он вызовет onCompleted и "лисенер" или Subscriber вызовется медот onCompleted() в котором то при получении НАПОЛНЕННЫХ классом orderStatus данных мы сможем присвоить их адаптеру adapter.set(List) и сделать adapterNotifyDataSetChanged.
но это только в теории, может кто нибудь написать коротенький скетч наполнения offerClass классом orderStatus через Object.setStatus(this.orderStatus) и считывания его в Subscriber???