基于Retrofit和Rxjava封装的请求工具类
Base Retrofit& Rxjava Encapsulates the request of the tools
RetrofitClient.getInstance(context)..createBaseApi().get("you path url"
,maps, maps, new Subscriber<IpResult>());
RetrofitClient.getInstance(context).createBaseApi().post("you path url"
,maps, maps, new Subscriber<IpResult>());
RequestBody jsonbody = RequestBody.create(okhttp3.MediaType.parse("application/json; charset=utf-8"), new Gson().toJson(user));
RetrofitClient.getInstance(MainActivity.this).createBaseApi().json("url", jsonBody, new BaseSubscriber<T>(context) {
}
#UpLoad
RequestBody requestFile =
RequestBody.create(MediaType.parse("image/jpg"), new File(mPath));
RetrofitClient.getInstance(MainActivity.this).createBaseApi().upload(url, requestFile, new Subscriber<ResponseBody>);
RetrofitClient.getInstance(MainActivity.this).createBaseApi().download(url1, new CallBack() {
@Override
public void onStart() {
super.onStart();
Toast.makeText(MainActivity.this, url1 + " is star", Toast.LENGTH_SHORT).show();
}
@Override
public void onError(Throwable e) {
}
@Override
public void onSucess(String path, String name, long fileSize) {
Toast.makeText(MainActivity.this, name + " is downLoaded", Toast.LENGTH_SHORT).show();
}
}
);
//create you APiService
MyApiService service = RetrofitClient.getInstance(MainActivity.this).create(MyApiService.class);
// execute and add observable
RetrofitClient.getInstance(MainActivity.this).execute(
service.getData("21.22.11.33"), new Subscriber<IpResult>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
Toast.makeText(MainActivity.this, e.getMessage(), Toast.LENGTH_LONG).show();
}
@Override
public void onNext(IpResult responseBody) {
Toast.makeText(MainActivity.this, responseBody.toString(), Toast.LENGTH_LONG).show();
}
});}
Author : Tamic
推荐使用：