rx android与mosby模式加载数据回收视图

Question

我正在开发一个Android应用程序。我附加的代码是创建一个回收视图。我们做的第一件事就是创建一个异步任务，它将获取SQLite数据库上的数据并将其加载到适配器->recylcerview中。当后台任务工作时，将向用户显示一个进度对话框。

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);
    }

}

}

到现在为止还好。但是，正如您可能知道的那样，这段代码有一些众所周知的问题；例如，如果我在异步任务执行其魔力时旋转屏幕，它将使应用程序崩溃。

我尝试过一种我见过的谷歌，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 onError(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();
}

}

现在，当我旋转屏幕时，这个应用程序不再崩溃了。然而，可观察的人一直在后台工作直到它完成，但由于我取消订阅以避免崩溃，我没有收到正确的结果。此外，进度栏消失了，即使可观察到的继续工作，正如我提到的。

在寻找解决方案时，我发现有一种叫做"Ted“的模式，它似乎解决了我的问题。虽然它看起来很有希望，但我认为这是太多的编码，我觉得这不值得，而且rxandroid可能有一个解决办法。

因此，我的问题是，我如何才能得到我想要的，而不陷入一个太大的架构编码混乱，我的目的？如果你们解决了这个问题，你们能举个例子吗？你认为我错了吗?我应该实现TedMosby模式吗？

Answer 1

Mosby是一个Model-View-Presenter (MVP)库。所以你命名为"ted模式“的模式实际上是MVP。

但你不知道MVP是怎么回事。这并不是为了保持异步运行taks，甚至认为这可以通过Mosby实现。MVP是关于分离关注点的。视图只是显示UI元素，演示者控制视图，即演示者告诉视图:现在显示进度对话框，现在隐藏进度对话框等等。换句话说，演示者控制视图的状态。模型可以是异步任务，也可以是可观察到的RxJava。演示者获得结果，并告诉视图显示它。您的代码被解耦为3层模型(也称为业务逻辑)和演示器和视图。其优点是您可以更改视图(即用进度条小部件替换进度对话框)，而无需接触任何加载数据的代码(演示者和业务逻辑)。另外，使用MVP，您的代码将变得可测试。

因此，您应该比较的是:我应该使用AsyncTask还是RxJava来加载数据？使用Mosby，您将在演示者中执行您的http请求。在完成方向更改时，演示程序不会被破坏(因此后台任务不会被取消)。

然而，MVP并不是所有问题的解决方案。如果您必须确保正确执行单个http调用(即注册一个社区)，那么您应该考虑使用android服务。

Answer 2

您可以做的是在活动中所做的任何事情，如AsycTask和RecyclerView，将其放入片段中，setRetainInstance(true)在片段的onCreateView()方法中，并在活动中加载该片段。

当屏幕旋转时，setRetainInstance(true)不会让您的片段实例破坏。

Answer 3

您的Observable应该处理自己取消订阅的事实。这方面有两种机制：

• 检查subscriber.isUnsubscribed。您可以在“沉重”步骤之间或之后执行此操作。
• 添加取消订阅回调。您可以使用它来停止长时间运行的操作，释放资源等。

看看下面的代码：

Observable.create(
        new Observable.OnSubscribe<List<items>>() {
            @Override
            public void call(Subscriber<? super List<items>> sub) {
                sub.add(Subscriptions.create(new Action0() {
                    @Override
                    public void call() {
                        cancelLongRunningOperationIfItStillRunning();
                    }
                }));
                if (!sub.isUnsubscribed()) {
                    //start long running operation here
               }
            }
        })
        .doOnSubscribe(new Action0() {
            @Override
            public void call() {
            }
        })

您不应该在Observable中引用活动/上下文/进度对话框等。相反，如果您想做一些副作用，可以使用doOnSubscribe。