rx android vs mosby模式加载数据recyclerview

我正在开发一款Android应用.我附上的代码是创建一个recyclerview.我们要做的第一件事就是创建一个asynctask,它将获取 sqlite数据库上的数据并将其加载到adapter-> recylcerview中.当后台任务正在运行时,会向用户显示progressdialog.

public class HomeActivity extends AppCompatActivity
{
    private RecyclerView recycler;
    private RecyclerViewAdapter adapter;
    private SwipeRefreshLayout swipeRefresh;
    private progressDialog progressDialog;

     // ... some code here

 @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        // ... some code here


    createRecyclerView();
    loadRecyclerView();


    // ... some code here

    }


    private void loadRecyclerView()
    {
        new LoadingBackgroundTask().execute();
    }



    private void createRecyclerView()
{

    Context context = getApplicationContext();

    recycler = (RecyclerView) findViewById(R.id.recycle_view_home);
    recycler.setHasFixedSize(true);

    RecyclerView.LayoutManager lManager = new linearlayoutmanager(context);
    recycler.setLayoutManager(lManager);

    adapter = new RecyclerViewAdapter();

    recycler.setAdapter(adapter);
    recycler.setItemAnimator(new DefaultItemAnimator());

}

private class LoadingBackgroundTask extends AsyncTask<Void, Void, List<items>> {

    @Override
    protected void onPreExecute() {
        super.onPreExecute();
        progressDialog = ProgressDialog.show(HomeActivity.this, getString(R.string.dialog_load_list),getString(R.string.dialog_please_wait), false, false);

    }

    @Override
    protected List doInBackground(Void... params) {

        List<items> lists;
        //Data Source Class ( sqlite)
        ListDS listDS = new ListDS(getApplicationContext());
        list = listDS.getList();

        return list;
    }

    @Override
    protected void onPostExecute(List result) {
        super.onPostExecute(result);

        //it inserts de list on recyclerview performing animation
        adapter.animate(result);

        progressDialog.dissmiss();
        swipeRefresh.setRefreshing(false);
        recycler.scrollToPosition(0);
    }

}

}

到现在为止还挺好.但是,您可能知道这段代码有一些众所周知的问题;例如,如果我在asynctask正在发挥其魔力的同时旋转屏幕,它将使应用程序崩溃.

我尝试了另一种我见过Googling,rxandroid的方法.

(对不起,如果我输错了,我是通过记忆来做的)

public class HomeActivity extends AppCompatActivity
{
 private Subscriber suscriptor;
private progressDialog progressDialog;

 //some code ....

  @Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    suscriptor = new Subscriber() {
        @Override
        public void onCompleted() {
            progressDialog.dismiss();
            Log.d("SUSCRIPTOR","ON COMPLETE");
        }

        @Override
        public void one rror(Throwable e) {
            Log.d("SUSCRIPTOR","ON ERROR");
        }

        @Override
        public void onNext(Object o) {
            adapter.animate((List<items>)o);

        }
    };


    Observable.create(
            new Observable.OnSubscribe<List<items>>() {
                @Override
                public void call(Subscriber<? super List<items>> sub) {
                progressDialog = ProgressDialog.show(HomeActivity.this,  getString(R.string.dialog_load_list),getString(R.string.dialog_please_wait), false, false);
                    List<items> lists;
                    //Data Source Class ( sqlite)
                    ListDS listDS = new ListDS(getApplicationContext());
                    list = listDS.getList();

                    sub.onNext(list);
                    sub.onCompleted();

                }

                @Override
                protected void finalize() throws Throwable {
                    super.finalize();
                    Log.d("OBSERAVBLE","FINALIZED");
                }
            })
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.newThread())
           .cache()
    .subscribe(suscriptor);

    }


@Override
public void onDestroy()
{
    if(suscriptor!=null)
    {
        if(!suscriptor.isUnsubscribed())
        {
            suscriptor.unsubscribe();
        }
    }

    super.onDestroy();
}

}

现在,当我旋转屏幕时,应用程序不再崩溃.但是,observable一直在后台工作直到完成,但是当我取消订阅以避免崩溃时,我没有正确地收到结果.而且,即使观察者像我提到的那样继续工作,进度条也会消失.

寻找解决方案,我发现有一种叫做“Ted Mosby”的模式似乎可以解决我的问题.虽然它看起来很有前途,但我认为编写的东西太多了,我觉得它不值得,rxandroid可能有一个解决方法.

所以,我的问题是如何才能获得我想要的东西,而不会沉浸在对我来说太大的架构编码混乱中？如果你们已经解决了这个问题,你能举个例子吗？你认为我错了,我应该实施TedMosby模式吗？

解决方法:

Mosby是一个模型 – 视图 – 演示者(MVP)库.所以你命名为“ted mosby pattern”的模式实际上就是MVP.

但是你并没有理解MVP的全部意义.这不是关于保持异步运行,甚至认为这可以通过Mosby实现. MVP是关于关注点的分离. View只显示UI元素,Presenter控制View,即演示者告诉视图：现在显示进度diaolog,现在隐藏进度对话框等.换句话说,演示者控制视图的状态.模型可以是异步任务或RxJava Observable. Presenter比返回结果并告诉视图显示它.您将代码解耦为3层模型(也称为业务逻辑)和Presenter和View.优点是您可以更改视图(即使用progressbar小部件替换进度对话框),而无需触及任何加载数据的代码(Presenter和业务逻辑).此外,使用MVP,您的代码变得可测试.

所以你要比较的是：我应该使用AsyncTask还是RxJava来加载数据.使用Mosby,您将在演示者中执行您的http请求.在完成方向更改时,演示者不会被销毁(因此后台任务不会被取消).

但是,MVP不是一切的解决方案.如果您必须确保正确执行单个http调用(即注册社区),您应该考虑使用Android服务.

rx android vs mosby模式加载数据recyclerview

相关推荐