NewMvp/app/src/main/java/com/miekir/newmvp/TestPresenter.java

package com.miekir.newmvp;

import android.util.Log;

import com.miekir.mvp.jetpack.BeanLiveData;
import com.miekir.mvp.presenter.BasePresenter;

import java.util.ArrayList;
import java.util.List;

/**
 * Copyright (C), 2019-2020, Miekir
 *
 * @author Miekir
 * @date 2020/10/6 20:53
 * Description:注意ViewModel的类必须是public的，否则无法创建实例
 */
public class TestPresenter extends BasePresenter {

    @Override
    public void init() {

    }

    private Thread thread;
    public BeanLiveData<List<TestBean1>, Thread> go() {
        final BeanLiveData<List<TestBean1>, Thread> liveData = getLiveData(true);

        thread = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    for (int i = 0; i < 20; i++) {
                        Thread.sleep(1000);
                        Log.i("test", "io thread..." + i);
                    }

                    TestBean1 bean = new TestBean1(3, "ViewModel Jason");
                    List<TestBean1> list = new ArrayList<>();
                    list.add(bean);
                    liveData.postSuccess(list);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
        liveData.setCancelableTask(thread);
        thread.start();

        return liveData;
    }

    @Override
    public void onTaskCancel() {
        super.onTaskCancel();
        if (thread != null) {
            try {
                thread.interrupt();
            } catch (Exception e) {
                e.printStackTrace();
            }

        }
    }
}