在RxJava适配器presenter中取消订阅RecyclerView

public class MyAdapter extends RecyclerView.Adapter<MyAdapter.ViewHolder> {
    private CompositeDisposable compositeDisposable = new CompositeDisposable();

    // ...

    public void setData(List<Data> data) {
        // 取消之前的订阅
        compositeDisposable.clear();

        // 处理数据流
        Disposable disposable = Observable.fromIterable(data)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<Data>() {
                    @Override
                    public void accept(Data data) throws Exception {
                        // 更新UI
                    }
                });

        // 添加新的订阅
        compositeDisposable.add(disposable);
    }

    // ...

    @Override
    public void onDetachedFromRecyclerView(@NonNull RecyclerView recyclerView) {
        super.onDetachedFromRecyclerView(recyclerView);
        // 取消所有订阅
        compositeDisposable.dispose();
    }

    // ...
}