在 RecyclerView Adapter 中使用 RxJava

Question

所以几周前我问了这个问题：。

今天我想使用 Rxjava 重构该功能。其实很简单，我是通过以下方式实现的：

 @Override
    public void onBindViewHolder(RecyclerView.ViewHolder holder, int position) {

                if (friend.getGameStatus().equals(GameStatus.INGAME)) {
                    holderOnline.startRepeatingTask();
                } else {
                    holderOnline.stopRepeatingTask();
                } 
    }


class MyViewHolderOnline extends RecyclerView.ViewHolder {

    private Subscription subscribe;

        public MyViewHolderOnline(View itemView) {
            super(itemView);
            ButterKnife.bind(this, itemView);

        }

        public void startRepeatingTask() {
            subscribe = Observable.interval(updateInterval, TimeUnit.MILLISECONDS)
                    .map(aLong -> current.getGameStatusToPrint())
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Subscriber<String>() {
                        @Override public void onCompleted() { }
                        @Override public void onError(Throwable e) { }

                        @Override
                        public void onNext(String gameStatusToPrint) {
                            gameStatus.setText(gameStatusToPrint);
                        }
                    });
        }

        void stopRepeatingTask() {
            if(subscribe != null && !subscribe.isUnsubscribed())
                subscribe.unsubscribe();
        }
    }

然而，问题是不同的。我有一个 navigationDrawer 实现了 Activity，这些活动在切换时暂停且未被销毁。因此，在我切换到不包含此适配器的 activity 之后，可观察对象继续发送内容，因为它是一个周期性间隔可观察对象。所以我的问题是，我该怎么办？当 activity 暂停时，我需要取消订阅，但我不知道从那以后如何取消订阅，也不知道如何重新订阅。有什么帮助或想法吗？

Answer 1

因此，如果我理解正确的话，解决问题的一种方法是回答以下问题：在包含 RecyclerView 的 Activity 中，如何获取对所有 ViewHolder 目前是 displayed/bound?

例如，要停止所有更新，您可以在 Activity 的 onPause() 中执行以下操作：

// assuming you are using a LinearLayoutManager:
final int firstVisibleIndex = mLinearLayoutManager.findFirstVisibleItemPosition();
final int lastVisibleIndex = mLinearLayoutManager.findLastVisibleItemPosition();

for (int i = firstVisibleIndex; i <= lastVisibleIndex; i++) {
    YourViewHolder viewHolder = (YourViewHolder) findViewHolderForAdapterPosition (i);
    viewHolder.stopRepeatingTask();
}

同样，您可以在 Activity 的 onResume 中重新启动任务。

BUT：既然我写了这篇文章，我不确定是否有 ViewHolders 超出 RecyclerView 的可见区域（即之前第一个或最后一个可见项目之后）已经绑定但无法使用此方法到达。如果事实证明是这种情况，您仍然可以遍历适配器中项目的所有索引并丢弃任何 null return 值。

在 RecyclerView Adapter 中使用 RxJava

Using RxJava inside RecyclerView Adapter

android

rx-java