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

package com.miekir.newmvp;

import android.util.Log;

import com.miekir.mvp.jetpack.RawLiveData;
import com.miekir.mvp.jetpack.WrapLiveData;
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() {

    }


    public Thread goWithWrapper(final WrapLiveData<List<TestBean1>> liveData) {
        Thread 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();
                }
            }
        });
        thread.start();
        return thread;
    }

    public Thread goWithoutWrap(final RawLiveData<List<TestBean1>> liveData) {
        Thread 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.post(list);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
        thread.start();
        return thread;
    }

    @Override
    public void onTaskCancel() {
        super.onTaskCancel();
    }
}