订阅多个 Observable 的适配器

Question

我的问题是适配器订阅多个可观察对象的最佳方式是什么

我有一个具有 header 和常规项目类型的适配器。适配器的信息是使用 Sqlbrite 从数据库中获取的。使用 Sqlbrite，我想通过让适配器订阅一个可观察对象来更新 header 和列表。

第一个 Observable 不是问题。在我片段的 OnResume 中：

    mSubscription = TrackerDbUtils.getListSubmissionObservable(db)
            .map(Submission.MAP)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(mAdapter);

但是，我随后尝试向片段添加第二个 Observable

    mHeaderSubscription = TrackerDbUtils.getSummaryObservable(db)
            .map(Summary.MAP)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(mAdapter);

所以，我需要在我的适配器中实现 Action1：

public class MileageTrackerAdapter extends HeaderRecyclerViewAdapter
    implements Action1<List<Submission>>, Action1<Summary> { 
    .
    .
    .

}

但是，我收到重复的 class 错误。所以我尝试实现一个通用类型：

public class MileageTrackerAdapter extends HeaderRecyclerViewAdapter
    implements Action1<Object> { 
    .
    .
    .
    @Override
    public void call(Object o) {
        if(o instanceof Summary){
              // Logic
        } else {
              // Logic
        }
    }
}

但是我收到一个运行时错误，提示我无法将摘要映射到提交。即使那样，我也不确定转换泛型是解决问题的最佳方法。

根据 dwursteisen 的反馈：

我更改了摘要 class 以映射到提交。我还创建了一个名为 "isSummary." 的新字段，我按照建议将我的 observable 更改为以下内容：

TrackerDbUtils.getListSubmissionObservable(db)
    .map(Submission.MAP)
    .mergeWith(TrackerDbUtils.getSummaryObservable(db)
                              .map(Summary.MAP))
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(mAdapter);

这将创建一个将触发两次的 Observable；一次是提交的批量列表，另一个是大小为 1 的列表。这个列表实际上是摘要。在我的适配器中：

@Override
public void call(List<Submission> mSubmissions) {

    if(mSubmissions.size() == 1 && mSubmissions.get(0).isSummary()){
        mSummary = mSubmissions.get(0);
    } else {
        mArray = new ArrayList<>(mSubmissions);
    }

    notifyDataSetChanged();

}

Answer 1

也许有人会给出更好的答案，但在这种情况下，我通常会创建这些接口的 public 最终匿名实例。所以代码看起来像这样：

public class Adapter extends HeaderRecyclerViewAdapter {

    public final Action1<Summary> summary = new Action1<Summary> { ... }
    public final Action1<List<Submission>> submissions = new Action1<List<Submission>> { ... }

}

这样，两个 Action1 实现中的方法都可以访问适配器 class 中的所有内容，就好像它们是普通方法一样，我可以通过使用 mAdapter.summary 或 mAdapter.submissions

Answer 2

你应该避免对两个不同的流使用相同的适配器，因为它必须处理并发问题，你可以避免使用 RxJava。

为什么不尝试将您的流合并为一个流，然后只使用一个适配器？

TrackerDbUtils.getListSubmissionObservable(db)
        .map(Submission.MAP)
        .mergeWith(TrackerDbUtils.getSummaryObservable(db)
                                  .map(Summary.MAP))
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(mAdapter);

您可能需要将 List<Submission> 和 Summary 映射到相同的通用类型，或者将 Object 处理到您的适配器中

订阅多个 Observable 的适配器

Adapter Subscribing to Multiple Observables

android

android-sqlite

baseadapter

rx-java

sqlbrite