Rxjava2, Retrofit2 - 在两个类之间传输数据。

Question

我有简单的 Observable。

public interface CitiesApi {
    @GET("location/cities")
    Observable<List<City>> getCities(@Query("country") String countryId);
}

我还有两个班级：

class Manager {

List<City> mList = new ArrayList();

public Observable<List<City>> getCitiesObservable(String countryId) {
// I want to update mList value in each new request;
 return CitiesApi.getCities(countryId);
}

二等：

class Presenter {

    public void request() {


    Manager.getCitiesObservable("us")
           .subscribeOn(Schedulers.newThread)
           .observeOn(AndroidSchedulers.mainThread)
           .subscribe(new ......)
        }

如您所见，我写了一条评论“我想在每个新请求中更新 mList 值”。 每次 Presenter 发出请求时，我如何更新 Manager 类中的 mList ？

Answer 1

您应该使用 RxJava 的转换运算符（如map）来实现您想要做的事情。这是所有运算符的列表 - ReactiveX - Operators

你可以这样做：

class Manager {

    List<City> mList = new ArrayList();

    public Observable<List<City>> getCitiesObservable(String countryId) {
        return CitiesApi.getCities(countryId)
                .subscribeOn(Schedulers.io())
                .map(new Function<List<City>, List<City>>() {
                    @Override
                    public List<City> apply(List<City> cities) throws Exception {
                        // Do your stuff and return a List<City> object
                    }
                });
    }
}

Answer 2

好的，这是我的承诺：

假设您设置了适配器并准备了您的mList，我就是这样做的。 调用请求并将响应正文放入变量的函数

private void makeGetMyChatsRequest(String searchWord){
    RestClient.getApi().getChats(searchWord).enqueue(new Callback<Chats>() {
        @Override
        public void onResponse(Call<Chats> call, Response<Chats> response) {
            if (response.isSuccessful())
                if (response.code() == 200){
                    chatsDatas = response.body().getChats();
                    chatAdapter.notifiDataSetChanged();
                }
        }

        @Override
        public void onFailure(Call<Chats> call, Throwable t) {
            Log.d(TAG, "-=onFailure=-\n" + t.getMessage());
        }
    });
}

这是改造界面

@GET(RestClient.API_GET_CHATS)
Call<Chats> getChats(@Query("username") String username);

它响应的对象的type，在我的例子中是<Chats>

public class Chats implements Serializable {
private ArrayList<ChatsData> chats;

public ArrayList<ChatsData> getChats() {
    return chats;
}

public void setChats(ArrayList<ChatsData> chats) {
    this.chats = chats;
}
}

因为我有一个数据数组，所以我还在这个数组中定义了数据的类型（将传递给请求调用函数上的chatsDatas 变量的确切数据。

public class ChatsData implements Serializable {
private int chat_room_id;
private int read;
private int user_id;
private String name;
private String picture;
private int is_online;
private LastMessageData last_message;
//here will be getters & setters for each field
}