订阅多个可观察对象的适配器

Question

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

我有一个适配器，它有一个头和常规项目类型。适配器的信息是使用Sqlbrite从数据库提供的。使用Sqlbrite，我想通过让适配器订阅一个可观察对象来更新标题和列表。

对于第一个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> { 
    .
    .
    .
}

但是，我得到一个重复的类错误。所以我尝试实现一个泛型类型:

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

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

基于dwursteisen的反馈:

我改变了Summary类来映射到Submission。我还创建了一个名为"isSummary"的新字段。我按照建议将可观察对象修改为:

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

您应该避免为两个不同的流使用相同的适配器，因为它将不得不处理并发问题，因此您可以避免使用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处理到适配器

Answer 2

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

public class Adapter extends HeaderRecyclerViewAdapter {
    public final Action1<Summary> summary = new Action1<Summary> { ... }
    public final Action1<List<Submission>> submissions = new Action1<List<Submission>> { ... }
}

这样，两个Action1实现中的方法可以访问Adapter类中的所有内容，就好像它们是普通方法一样，我可以通过使用mAdapter来区分它们。摘要或madapter . submitted