1.延迟请求
延迟n秒后再去请求
public static Observable<Long> timer(long delay, TimeUnit unit) {
return timer(delay, unit, Schedulers.computation());
}
然后使用flatmap转换
//延迟5s请求
Observable.timer(5, TimeUnit.SECONDS).flatMap(new Function<Long, ObservableSource<SkinTestResult>>() {
@Override
public ObservableSource<SkinTestResult> apply(@NonNull Long aLong) throws Exception {
//延迟结束开始执行网络请求
Observable<SkinTestResult> observable = EasyHttp.get("/v1/app/chairdressing/skinAnalyzePower/skinTestResult")
.timeStamp(true)
.execute(SkinTestResult.class);
return observable;
}
}).subscribe(new BaseSubscriber<SkinTestResult>() {
@Override
protected void onStart() {
}
@Override
public void onError(ApiException e) {
showToast(e.getMessage());
}
@Override
public void onNext(@NonNull SkinTestResult skinTestResult) {
Log.i("test", "=====" + skinTestResult.toString());
}
});
//在不需要轮询的时候，取消轮询
//EasyHttp.cancelSubscription(polldisposable);
2.轮询请求-无限轮询
//自己根据需要选择合适的interval方法
Disposable polldisposable = Observable.interval(0, 5, TimeUnit.SECONDS).flatMap(new Function<Long, ObservableSource<Content>>() {
@Override
public ObservableSource<Content> apply(@NonNull Long aLong) throws Exception {
return EasyHttp.get("/ajax.php")
.baseUrl("http://fy.iciba.com")
.params("a", "fy")
.params("f", "auto")
.params("t", "auto")
.params("w", "hello world")
//采用代理
.execute(new CallClazzProxy<TestApiResult6<Content>, Content>(Content.class) {
});
}
}).subscribeWith(new BaseSubscriber<Content>() {
@Override
public void onError(ApiException e) {
showToast(e.getMessage());
}
@Override
public void onNext(@NonNull Content content) {
showToast(content.toString());
}
});
//在不需要轮询的时候，取消轮询
//EasyHttp.cancelSubscription(polldisposable);
3.轮询请求-限定次数轮询
int count = 3;//轮询3次
//方式一：采用intervalRange
//Observable.intervalRange(0,count,0,5, TimeUnit.SECONDS).flatMap(new Function<Long, ObservableSource<Content>>() {
//方式一：采用take ,take的意思是取前几次使用，后面直接抛弃
countdisposable = Observable.interval(0, 5, TimeUnit.SECONDS).take(count).flatMap(new Function<Long, ObservableSource<Content>>() {
@Override
public ObservableSource<Content> apply(@NonNull Long aLong) throws Exception {
return EasyHttp.get("/ajax.php")
.baseUrl("http://fy.iciba.com")
.params("a", "fy")
.params("f", "auto")
.params("t", "auto")
.params("w", "hello world")
//采用代理
.execute(new CallClazzProxy<TestApiResult6<Content>, Content>(Content.class) {
});
}
}).subscribeWith(new BaseSubscriber<Content>() {
@Override
public void onError(ApiException e) {
showToast(e.getMessage());
}
@Override
public void onNext(@NonNull Content content) {
showToast(content.toString());
}
});
//在不需要轮询的时候，取消轮询
//EasyHttp.cancelSubscription(polldisposable);
4.轮询请求-条件轮询
Observable.interval(0, 5, TimeUnit.SECONDS).flatMap(new Function<Long, ObservableSource<Content>>() {
@Override
public ObservableSource<Content> apply(@NonNull Long aLong) throws Exception {
return EasyHttp.get("/ajax.php")
.baseUrl("http://fy.iciba.com")
.params("a", "fy")
.params("f", "auto")
.params("t", "auto")
.params("w", "hello world")
//采用代理
.execute(new CallClazzProxy<TestApiResult6<Content>, Content>(Content.class) {
});
}
}).takeUntil(new Predicate<Content>() {
@Override
public boolean test(@NonNull Content content) throws Exception {
//如果条件满足，就会终止轮询，这里逻辑可以自己写
//结果为true，说明满足条件了，就不在轮询了
return content.getOut().contains("示");
}
}).subscribeWith(new BaseSubscriber<Content>() {
@Override
public void onError(ApiException e) {
showToast(e.getMessage());
}
@Override
public void onNext(@NonNull Content content) {
showToast(content.toString());
}
});
//在不需要轮询的时候，取消轮询
//EasyHttp.cancelSubscription(polldisposable);
5.过滤失败的情况，只有成功才显示
Disposable filterdisposable = Observable.interval(0, 5, TimeUnit.SECONDS).flatMap(new Function<Long, ObservableSource<Content>>() {
@Override
public ObservableSource<Content> apply(@NonNull Long aLong) throws Exception {
return EasyHttp.get("/ajax.php")
.baseUrl("http://fy.iciba.com")
.params("a", "fy")
.params("f", "auto")
.params("t", "auto")
.params("w", "hello world")
//采用代理
.execute(new CallClazzProxy<TestApiResult6<Content>, Content>(Content.class) {
});
}
}).filter(new Predicate<Content>() {
@Override
public boolean test(@NonNull Content content) throws Exception {
//如果不满足条件就过滤该条轮询数据，但是轮询还是一直执行
//ErrNo==0表示成功，如果不等于0就认为失败，content不会返回给订阅者
return content.getErrNo() != 0;
}
}).subscribeWith(new BaseSubscriber<Content>() {
@Override
public void onError(ApiException e) {
showToast(e.getMessage());
}
@Override
public void onNext(@NonNull Content content) {
showToast(content.toString());
}
});
//在不需要轮询的时候，取消轮询
//EasyHttp.cancelSubscription(polldisposable);
6 嵌套使用例如需要先去服务器请求taken然后再拿这个token再去请求数据
//第一个网络请求获取到token
Observable<AuthModel> login = EasyHttp.post(ComParamContact.Login.PATH)
.params(ComParamContact.Login.ACCOUNT, "186****4275")
.params(ComParamContact.Login.PASSWORD, MD5.encrypt4login("123456", AppConstant.APP_SECRET))
.sign(true)
.timeStamp(true).execute(AuthModel.class);
login.flatMap(new Function<AuthModel, ObservableSource<SkinTestResult>>() {
@Override
public ObservableSource<SkinTestResult> apply(@NonNull AuthModel authModel) throws Exception {
//获取到的token，给到第二个网络当参数。第二个网络开始请求
return EasyHttp.get("/v1/app/chairdressing/skinAnalyzePower/skinTestResult")
.params("accessToken", authModel.getAccessToken())//这个地方只是举例，并不一定是需要accessToken
.timeStamp(true)
.execute(SkinTestResult.class);
}
}).subscribe(new ProgressSubscriber<SkinTestResult>(this, mProgressDialog) {
@Override
public void onError(ApiException e) {
super.onError(e);
showToast(e.getMessage());
}
@Override
public void onNext(SkinTestResult skinTestResult) {
showToast(skinTestResult.toString());
}
});
其实就是使用的flatmap
转自http://blog.csdn.net/zhouy478319399/article/details/78550248
网友评论