本文整理汇总了Java中me.jessyan.rxerrorhandler.handler.RetryWithDelay类的典型用法代码示例。如果您正苦于以下问题:Java RetryWithDelay类的具体用法?Java RetryWithDelay怎么用?Java RetryWithDelay使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RetryWithDelay类属于me.jessyan.rxerrorhandler.handler包,在下文中一共展示了RetryWithDelay类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: requestUserDetail
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestUserDetail() {
mModel.getUserDetail()
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<UserDetail>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<UserDetail>>(mErrorHandler) {
@Override
public void onNext(BaseJson<UserDetail> userDetailBaseJson) {
if (userDetailBaseJson.getStatus() == 0) {
UserDetail data = userDetailBaseJson.getData();
mRootView.setUserDetail(data);
} else {
mRootView.showMessage(userDetailBaseJson.getMsgs());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:20,代码来源:FragmentPresenter.java
示例2: requestAddressSave
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestAddressSave(Address address) {
mModel.saveAddress(address)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> listBaseJson) {
if (listBaseJson.getStatus() == 0) {
mRootView.refreshAddress();
} else {
String str = listBaseJson.getMsgs();
mRootView.showMessage(str);
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:20,代码来源:AddressPresenter.java
示例3: setdefault
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void setdefault(int position) {
Address objAddress = mAddresses.get(position);
if (objAddress.getId() <= 0) {
mRootView.showMessage("请选择设置项");
return;
}
mModel.setDefaultAddress(objAddress.getId())
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> listBaseJson) {
mRootView.showMessage(listBaseJson.getMsgs());
requestAddress(true);
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:20,代码来源:AddressPresenter.java
示例4: requestAddressDetail
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestAddressDetail(int id) {
mModel.getAddressDetail(id)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new ErrorHandleSubscriber<BaseJson<Address>>(mErrorHandler) {
@Override
public void onNext(BaseJson<Address> listBaseJson) {
if (listBaseJson.getStatus() == 0) {
mRootView.setAddressDetail(listBaseJson.getData());
} else {
mRootView.showMessage(listBaseJson.getMsgs());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:19,代码来源:AddressPresenter.java
示例5: requestAddressImage
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
/**
* 请求身份证图片
* @param i
* @param url
*/
public void requestAddressImage(int i, String url) {
mModel.getAddressImage(url)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<String>>bindToLifecycle(mRootView))//使用RXlifecycle,使subscription和activity一起销毁
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.setImage(i,jsonObjectBaseJson.getData());
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:24,代码来源:AddressPresenter.java
示例6: requestRegister
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestRegister(String name, String email, String pwd, String code, String invite) {
mModel.register(name, email, pwd, code, invite)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<JsonObject>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<JsonObject>>(mErrorHandler) {
@Override
public void onNext(BaseJson<JsonObject> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.UserResult(jsonObjectBaseJson.getData());
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
@Override
public void onError(Throwable e) {
super.onError(e);
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:26,代码来源:UserPresenter.java
示例7: requestLogin
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestLogin(String name, String pwd) {
mModel.login(name, pwd)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<JsonObject>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<JsonObject>>(mErrorHandler) {
@Override
public void onNext(BaseJson<JsonObject> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.UserResult(jsonObjectBaseJson.getData());
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:20,代码来源:UserPresenter.java
示例8: requestLogout
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestLogout(Activity activity) {
mModel.logout()
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<String>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
// mRootView.showMessage(jsonObjectBaseJson.getMsgs());
activity.finish();
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:21,代码来源:UserPresenter.java
示例9: requestForget
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestForget(String phone, String pwd, String code) {
mModel.forget(phone, pwd, code)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<String>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.UserResult(null);
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:20,代码来源:UserPresenter.java
示例10: requestUserVip
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestUserVip() {
mModel.getUserVip()
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<JsonObject>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<JsonObject>>(mErrorHandler) {
@Override
public void onNext(BaseJson<JsonObject> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
String member = jsonObjectBaseJson.getData().get("member").getAsString();
String expiryDate = jsonObjectBaseJson.getData().get("expiryDate").getAsString();
String balanceCny = jsonObjectBaseJson.getData().get("balanceCny").getAsString();
mRootView.setUserVip(member, expiryDate, balanceCny);
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:24,代码来源:UserPresenter.java
示例11: requestPayRechare
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestPayRechare(String rechare, double paymoney) {
mModel.getPayRecharge(rechare, paymoney)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<String>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> stringBaseJson) {
if (stringBaseJson.getStatus() == 0) {
mRootView.aliPayReturn(stringBaseJson.getData());
} else {
mRootView.showMessage(stringBaseJson.getData());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:20,代码来源:UserPresenter.java
示例12: requestAlterPassword
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
/**
* 修改密码
*
* @param
*/
public void requestAlterPassword(String originalPassword, String password, String confirmedPassword) {
mModel.alterpassword(originalPassword, password, confirmedPassword)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<JsonObject>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<JsonObject>>(mErrorHandler) {
@Override
public void onNext(BaseJson<JsonObject> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
mRootView.alterPassword();
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:26,代码来源:UserPresenter.java
示例13: requestUserInfo
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
/**
* 获取个人资料
*/
public void requestUserInfo() {
mModel.getUserInfo()
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<User>>bindToLifecycle(mRootView))//使用RXlifecycle,使subscription和activity一起销毁
.subscribe(new ErrorHandleSubscriber<BaseJson<User>>(mErrorHandler) {
@Override
public void onNext(BaseJson<User> userBaseJson) {
if (userBaseJson.getStatus() == 0) {
mRootView.SetUserInfo(userBaseJson.getData());
} else {
mRootView.showMessage(userBaseJson.getMsgs());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:24,代码来源:UserPresenter.java
示例14: requestAlterCustomer
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
/**
* 修改个人资料
*
* @param user
*/
public void requestAlterCustomer(User user) {
mModel.altercustomer(user)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<String>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.showMessage("修改成功!");
mAppManager.getCurrentActivity().setResult(CodeDefine.MINE_EDIT_RESULT);
mAppManager.getCurrentActivity().finish();
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:27,代码来源:UserPresenter.java
示例15: requestWarehouse
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
/**
* 获取仓库列表
*/
public void requestWarehouse() {
mModel.getwarehouse()
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<WarehousJson>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<WarehousJson>(mErrorHandler) {
@Override
public void onNext(WarehousJson warehousJson) {
if (warehousJson.getStatus() == 0) {
for (WarehouseList warehouses : warehousJson.getData()) {
mWarehouseList.add(warehouses);
}
mAdapter.notifyDataSetChanged();
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:25,代码来源:UserPresenter.java
示例16: getWarehouse
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void getWarehouse() {
mModel.getWarehouses()
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<List<Warehouse>>>bindToLifecycle(mRootView))//使用RXlifecycle,使subscription和activity一起销毁
.subscribe(new ErrorHandleSubscriber<BaseJson<List<Warehouse>>>(mErrorHandler) {
@Override
public void onNext(BaseJson<List<Warehouse>> listBaseJson) {
if (listBaseJson.getStatus() == 0) {
List<Warehouse> data = listBaseJson.getData();
mRootView.ListWarehouses(data);
} else {
mRootView.showMessage(listBaseJson.getMsgs());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:22,代码来源:PackagePresenter.java
示例17: putPackageImage
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
/**
* 上传包裹截图
*
* @param mImage1
* @param mImage2
* @param mImage3
*/
public void putPackageImage(String mImage1, String mImage2, String mImage3) {
mModel.putPackageImage(mImage1, mImage2, mImage3)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<JsonObject>>bindToLifecycle(mRootView))//使用RXlifecycle,使subscription和activity一起销毁
.subscribe(new ErrorHandleSubscriber<BaseJson<JsonObject>>(mErrorHandler) {
@Override
public void onNext(BaseJson<JsonObject> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.packageImage(jsonObjectBaseJson.getStatus());
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
mRootView.packageImage(jsonObjectBaseJson.getStatus());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:29,代码来源:PackagePresenter.java
示例18: uploadPackageImage
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void uploadPackageImage(Bitmap bitmap1, Bitmap bitmap2, Bitmap bitmap3) {
mModel.uploadPackageImage(bitmap1, bitmap2, bitmap3)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<JsonObject>>bindToLifecycle(mRootView))//使用RXlifecycle,使subscription和activity一起销毁
.subscribe(new ErrorHandleSubscriber<BaseJson<JsonObject>>(mErrorHandler) {
@Override
public void onNext(BaseJson<JsonObject> jsonObjectBaseJson) {
if (jsonObjectBaseJson.getStatus() == 0) {
mRootView.packageImage(jsonObjectBaseJson.getStatus());
} else {
mRootView.showMessage(jsonObjectBaseJson.getMsgs());
mRootView.packageImage(jsonObjectBaseJson.getStatus());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:22,代码来源:PackagePresenter.java
示例19: requestCalcuteFee
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requestCalcuteFee(List<Integer> inventorys, int warehouseId, int numberInventory, double estimatedWeight, String ordertype, String couponCode, int ordertypeId, int leadId, String orderNo) {
mModel.calculateFee(inventorys, warehouseId, numberInventory, estimatedWeight, ordertype, couponCode, ordertypeId, leadId, orderNo)
.subscribeOn(Schedulers.io()) //指定 subscribe() 发生在 IO 线程
.retryWhen(new RetryWithDelay(3, 2))//遇到错误时重试,第一个参数为重试几次,第二个参数为重试的间隔
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread()) //指定 Subscriber 的回调发生在主线程
.compose(RxUtils.<BaseJson<Fee>>bindToLifecycle(mRootView))//使用RXlifecycle,使subscription和activity一起销毁
.subscribe(new ErrorHandleSubscriber<BaseJson<Fee>>(mErrorHandler) {
@Override
public void onNext(BaseJson<Fee> listBaseJson) {
if (listBaseJson.getStatus() == 0) {
mRootView.setFeeValue(listBaseJson.getData());
} else {
mRootView.showMessage(listBaseJson.getMsgs());
}
}
});
}
开发者ID:Zyj163,项目名称:yyox,代码行数:21,代码来源:OrderPresenter.java
示例20: requsetpayOrder
import me.jessyan.rxerrorhandler.handler.RetryWithDelay; //导入依赖的package包/类
public void requsetpayOrder(String orderld, String comments, double price, String payTypeBackSide) {
mModel.getPayOder(orderld, comments, price, payTypeBackSide)
.subscribeOn(Schedulers.io())
.retryWhen(new RetryWithDelay(3, 2))
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(AndroidSchedulers.mainThread())
.compose(RxUtils.<BaseJson<String>>bindToLifecycle(mRootView))
.subscribe(new ErrorHandleSubscriber<BaseJson<String>>(mErrorHandler) {
@Override
public void onNext(BaseJson<String> listBaseJson) {
if (listBaseJson.getStatus() == 0) {
mRootView.setOrderInfo(listBaseJson.getData());
} else {
mRootView.showMessage(listBaseJson.getMsgs());
}
}
}
);
}
开发者ID:Zyj163,项目名称:yyox,代码行数:21,代码来源:OrderPresenter.java
注:本文中的me.jessyan.rxerrorhandler.handler.RetryWithDelay类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论