Adnroid-MVVM-demo

package com.kevin.mvvmdemo; import android.app.Application; import android.content.Context; import android.content.SharedPreferences; import com.kevin.mvvmdemo.bean.HttpResult; import java.util.concurrent.TimeUnit; import io.reactivex.Observable; import io.reactivex.ObservableEmitter; import io.reactivex.ObservableOnSubscribe; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.schedulers.Schedulers; /** * NetWork * * @author zwenkai@foxmail.com, Created on 2018-09-20 17:01:19 * Major Function：<b></b> * <p/> * Note: If you modify this class please fill in the following content as a record. * @author mender，Modified Date Modify Content: */ public class NetWork { private Application mApplication; public NetWork(Application application) { this.mApplication = application; } public Observable<HttpResult<String>> saveData(final String content) { return Observable.create( new ObservableOnSubscribe<HttpResult<String>>() { @Override public void subscribe(ObservableEmitter<HttpResult<String>> e) { SharedPreferences sp = mApplication.getSharedPreferences("demo", Context.MODE_PRIVATE); boolean success = sp.edit().putString("content", content).commit(); HttpResult httpResult = new HttpResult(); if (success) { httpResult.status = 200; httpResult.msg = "保存成功"; } else { httpResult.status = 5; httpResult.msg = "保存失败"; } httpResult.data = content; e.onNext(httpResult); e.onComplete(); } } ) .delay(2, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()); } public Observable<HttpResult<String>> loadData() { return Observable.create( new ObservableOnSubscribe<HttpResult<String>>() { @Override public void subscribe(ObservableEmitter<HttpResult<String>> e) { SharedPreferences sp = mApplication.getSharedPreferences("demo", Context.MODE_PRIVATE); HttpResult httpResult = new HttpResult(); httpResult.data = sp.getString("content", ""); httpResult.status = 200; httpResult.msg = "获取成功"; e.onNext(httpResult); e.onComplete(); } } ) .delay(2, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()); } }