pengyuantao / mantis Goto Github PK

//建议在Application的中进行Mantis的初始化操作，各种Builder详见Demo中
    Mantis.getInstance().init(this);
    //设置显示EmptyView，ErrorView，NetErrorView的Builder
    Mantis.getInstance().setHintConfigBuilder(getDefaultHintConfigBuilder());
    //设置页面刷新相关的配置
    Mantis.getInstance().setRefreshConfigBuilder(getDefaultRefreshBuilder());
    //设置列表页面的相关的配置
    Mantis.getInstance().setListConfigBuilder(getDefaultListBuilder());

/**
 * 
 *加入使用的是MantisDataContract协议
 */
public interface TestDataContract{
    interface View extends MantisDataContract.View<Present,String>{
        void toast (String msg);
    }
    interface Present extends MantisDataContract.Present<View,String>{
        void login (String account, String password);
        void logout ();
    }
}

/**
* Fragment （View）的定义，继承TestDataContract.View接口，传入对应的泛型
* 使用BindPresent注解指定这个Fragment需要进行引用的Present具体的实现类
*/
@BindPresent(value = TestDataPresent.class)
public class TestDataFragment extends MantisDataFragment<TestDataContract.Present, String> implements TestDataContract.View{}

/**
 * Present的定义，继承TestDataContract.Present接口，传入对应的泛型
 * 
 */
public class TestDataPresent extends MantisDataPresent<TestDataContract.View, String> implements TestDataContract.Present {}

//在View中可以通过getPresent()方法获取Present实例，从而调用Present在协议中提供的api，在Present中通过getView()方法获取View的实例，从而调用View在协议中提供的api。

Observable.<String>create(subscriber -> subscriber.onNext("登录成功  账号：" + account + "  密码：" + password))
                .delay(2, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                //如果是Rxjava通过下面的用法进行绑定
                .compose(bindUntilEvent(PresentEvent.DESTROY))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(s -> {
                            publishData(s);
                            Log.i(TAG, "login: 执行onNext");
                        }
                        , throwable -> {
                            publishError(throwable);
                            Log.i(TAG, "login: 执行onError");
                        }
                        , () -> {
                            Log.i(TAG, "login: 执行onComplete");
                        });

  @Override
    public void reload() {
        reloadIndex++;
        Log.i(TAG, "reload: index [ " + reloadIndex + " ]");
        if ( reloadIndex == 1) {
            createCommonObservable("", 1).subscribe(s -> getViewDelegate().showNetworkErrorView());
            Log.i(TAG, "reload:显示网络异常View");
        } else if ( reloadIndex == 2) {
            createCommonObservable("", 1) .subscribe(s -> getViewDelegate().showErrorView("十分的抱歉", "由于攻城狮GG的失误，导致程序的奔溃，截此图奖励9999999元"));
            Log.i(TAG, "reload: 显示程序错误View");
        }else {
            createCommonObservable("恭喜恭喜，终于显示ContentView了，来自不易啊!", 1).subscribe(s -> publishData(s), throwable -> publishError(throwable));
            Log.i(TAG, "reload: 显示内容View");
            reloadIndex = 0;
        }
    }

@Override
    public View onCreateView(LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState, HintConfig.Builder hintBuilder, RefreshConfig.Builder refreshBuilder) {
        refreshBuilder.autoRefresh(false);
        return inflater.inflate(R.layout.fragment_test_refresh, container, false);
    }