admin/July
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

d

Browse Source
This commit is contained in:
jianbo
2020-08-25 10:08:00 +08:00
parent 288ce9cd0c
commit 2d9e287f09
222 changed files with 1570 additions and 692 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
app/src/main/java/com/fenghoo/seven/okgonet/Func1.java Normal file
View File

@@ -0,0 +1,15 @@
package com.fenghoo.seven.okgonet;
/**
* ================================================
* 作 者：jeasonlzy（廖子尧）Github地址：https://github.com/jeasonlzy
* 版 本：1.0
* 创建日期：2017/2/6
* 描 述：
* 修订历史：
* ================================================
*/
public interface Func1<T, R> {
//把一个结果转为我们需要的一个结果
R call(T t);
}

434
app/src/main/java/com/fenghoo/seven/okgonet/HttpConstants.java Normal file
View File

@@ -0,0 +1,434 @@
package com.fenghoo.seven.okgonet;
/**
* 项目名：JiaJieSong
* 包名：com.fanghoo.jiajiesong.http
* 文件名：HttpConstants
* 创建者：任剑波
* 创建时间：2017/10/22 0022 23:05
* 描述：所有请求相关地址
*/
public class HttpConstants {
// public static String URiBase = "http://www.fenghoo.com.cn";// 蜂狐商户版线上
public static String URiBase = "http://192.168.1.3";// 7月7
/**
* 蜂狐商户版
*/
/**
* 账号密码登录
*/
public static String URi_device_DevLogin_accountPwd = URiBase + "/device/DevLogin/accountPwd";
/**
* 获取验证码
*/
public static String URi_device_DevSendSMS_send = URiBase + "/device/DevSendSMS/send";
/**
* 手机号登录登录接口
*/
public static String Uri_device_SendSMS_checkCode = URiBase + "/device/SendSMS/checkCode";
/**
* 手机号验证码登录
*/
public static String Uri_device_DevSendSMS_checkCode = URiBase + "/device/DevSendSMS/checkCode";
/**
* 找回密码
*/
public static String URi_device_DevLogin_changePwd = URiBase + "/device/DevLogin/changePwd";
/**
* 订单—订单审核和审核完成接口
*/
public static String Uri_device_DevOrder_checkOrderInfo = URiBase + "/device/DevOrder/checkOrderInfo";
/**
* 退换货—退货单待审核和审核完成
*/
public static String Uri_device_DevOrder_checkReturnInfo = URiBase + "/device/DevStock/checkReturnInfo";
/**
* 查询是否绑定摄像头
*/
public static String URi_is_bind_camera = URiBase + "/device/DevLogin/checkCamera";
/**
* 打标：获取打标问题
*/
public static String URi_get_marking_requestion = URiBase + "/device/DevMark/getMarkProblem";
/**
* 打标：提交标签
*/
public static String URi_commit_tag = URiBase + "/device/DevMark/submitMarkInfo";
/**
* 打标：黑名单提交记录
*/
public static String URi_DevJoinGood_BlackList = URiBase + "/device/DevJoinGood/BlackList";
/**
* 获取雷达图数据
*/
public static String Uri_device_DevMark_styleRadar = URiBase + "/device/DevMark/styleRadar";
/**
* 订单—搜索手机号
*/
public static String Uri_device_DevOrder_SearchPhone = URiBase + "/device/DevOrder/searchPhone";
/**
* 订单—搜索手机号
*/
public static String Uri_device_DevOrder_GetOrderNum = URiBase + "/device/DevOrder/getOrderNum";
/**
* 订单—获取店铺
*/
public static String Uri_device_DevOrder_GetStoreName = URiBase + "/device/DevOrder/getStoreInfo";
/**
* 退换货—退货单提交页面
*/
public static String Uri_device_DevOrder_ReturnGoods = URiBase + "/device/DevStock/returnGoods";
/**
* 退货—退货单转开订单
*/
public static String Uri_device_DevOrder_OrderChangeGood = URiBase + "/device/DevStock/OrderChangeGood";
/**
* 退换货—退货单详细信息
*/
public static String Uri_device_DevOrder_ReturnOrderDetail = URiBase + "/device/DevStock/ReturnOrderDetail";
/**
* 退换货—审核通过和审核驳回---店长
*/
public static String Uri_device_DevOrder_ReturnOrderPass = URiBase + "/device/DevStock/ReturnOrderPass";
/**
* 退换货—退换单提交审核
*/
public static String Uri_device_DevOrder_SubmitReturnAudit = URiBase + "/device/DevStock/submitReturnAudit";
/**
* 订单—分享订单获取奖励
*/
public static String Uri_device_DevOrder_GetOrderAward = URiBase + "/device/DevOrder/getOrderAward";
/**
* 订单—订单详细信息接口
*/
public static String Uri_device_DevOrder_OrderDetail = URiBase + "/device/DevOrder/orderDetail";
/**
* 退货—历史退货单
*/
public static String Uri_device_DevOrder_HistoryReturnOrder = URiBase + "/device/DevStock/HistoryReturnOrder";
/**
* 订单—新建订单接口
*/
public static String Uri_device_DevOrder_CreatOrder = URiBase + "/device/DevOrder/creatOrder";
/**
* 订单—保存订单的详细信息
*/
public static String Uri_device_DevOrder_GetSaveInfomation = URiBase + "/device/DevOrder/getSaveInfomation";
/**
* 订单--草稿箱
*/
public static String Uri_device_DevOrder_GetSaveRecord = URiBase + "/device/DevOrder/getSaveRecord";
/**
* 库存查询—品牌查询
*/
public static String Uri_device_DevStock_GetStockFind = URiBase + "/device/DevStock/getStockFind";
/**
* 库存查询—预定商品订单
*/
public static String Uri_device_DevStock_GetStockOrderGoods = URiBase + "/device/DevStock/getStockOrderGoods";
/**
* 订单—新建订单接口
*/
public static String Uri_device_DevOrder_AddGoods = URiBase + "/device/DevOrder/addGoods";
/**
* 打标：关联
*/
public static String Uri_device_DevMark_relationVsitor = URiBase + "/device/DevMark/relationVsitor";
/**
* 打标：关联历史
*/
public static String Uri_device_DevMark_relationHistory = URiBase + "/device/DevMark/relationHistory";
/**
* 打标：我的客户-更改状态
*/
public static String URi_device_DevOrder_updatetime = URiBase + "/device/DevMark/updatetime";
/**
* 订单--保存订单
*/
public static String URi_device_DevOrder_GetBaveInfo = URiBase + "/device/DevOrder/getBaveInfo";//submitAudit
/**
* 订单—提交审核
*/
public static String URi_device_DevOrder_submitAudit = URiBase + "/device/DevOrder/submitAudit";//submitAudit
/**
* 订单—审核通过或审核驳回--店长
*/
public static String URi_device_DevOrder_orderPass = URiBase + "/device/DevOrder/orderPass";
/**
* 订单--获取历史凭证
*/
public static String URi_device_DevOrder_getHistoryProof = URiBase + "/device/DevOrder/getHistoryProof";
/**
* 我的--绑定摄像头
*/
public static String URi_device_Bind_Camera = URiBase + "/device/DevLogin/bindCamera";
/**
* 微信登录
*/
public static String URi_device_DevLogin_wechatLogin = URiBase + "/device/DevLogin/wechatLogin";
/**
* 退出登录
*/
public static String URi_device_DevLogin_exitLogin = URiBase + "/device/DevLogin/exitLogin";
/**
* 微信绑定手机号
*/
public static String URi_device_DevLogin_BlindPhone = URiBase + "/device/DevLogin/bindPhone";
/**
* 获取用户基本信息
*/
public static String URi_user_Base_Msg = URiBase + "/device/DevMark/visitorInfo";
/**
* 获取打标详细信息
*/
public static String URi_marking_detail_msg = URiBase + "/device/DevMark/markDetails";
/**
* 成交报备详细信息
*/
public static String URi_device_DevMark_orderDetails = URiBase + "/device/DevMark/orderDetails";
// /**
// * 打标：确认关联
// */
// public static String URi_marking_confirm_relevance = URiBase + "/device/DevMark/sureRelation";
/**
* 打标：进店记录搜索
*/
public static String URi_marking_enter_store_search = URiBase + "/device/DevMark/searchHistory";
/**
* 我的页面：登录人信息
*/
public static String URi_logged_msg = URiBase + "/device/DevLogin/loginInfomation";
/**
* 我的客户--筛选店员名称
*/
public static String URi_DevMark_screenfVisitor = URiBase + "/device/DevMark/screenfVisitor";
/**
* 我的：提现
*/
public static String URi_withdrawal = URiBase + "/device/DevLogin/withDrawal";
/**
* 我的：微信提现
*/
public static String URi_WECHAT_MONEY = URiBase + "/device/DevLogin/wechatTX";
/**
* 我的:收支明细
*/
public static String URi_detial_discraption = URiBase + "/device/DevLogin/paymentDetail";
/**
* 我的:退回账户余额
*/
public static String URi_back_account_balance = URiBase + "/device/DevLogin/returnBalance";
/**
* 打标：获取今日打标及未打标的顾客信息 全部客户
*/
public static String URi_device_DevMark_showVisitor = URiBase + "/device/DevMark/showVisitor";
/**
* 我的页面—名单管理
*/
public static String URi_get_from_manager = URiBase + "/device/DevClient/CustormList";
/**
* 客户分配---待分配客户列表
*/
public static String URi_get_from_waitingAssigned = URiBase + "/device/DevClient/waitingAssigned";
/**
* 客户分配--店员列表
*/
public static String URi_get_from_assignUser = URiBase + "/device/DevClient/assignUser";
/**
* 我的页面—名单管理--移出
*/
public static String URi_get_from_manager_remove = URiBase + "/device/DevClient/RemoverCustorm";
/**
* 我的页面—获取当前版本号
*/
public static String URi_Device_DevLogin_NowVersion = URiBase + "/device/DevLogin/NowVersion";
/**
* 我的页面—同一个人所属店铺
*/
public static String URi_Device_DevClient_AllStore = URiBase + "/device/DevClient/AllStore";
/**
* 我的页面—切换店铺
*/
public static String URi_Device_DevClient_SwitchStore = URiBase + "/device/DevClient/SwitchStore";
/**
* 上传头像
*/
public static String URi_Device_Device_UploadImg = URiBase + "/device/DevClient/UploadImg";
/**
* 上传二维码
*/
public static String URi_Device_DevLogin_uplCode = URiBase + "/device/DevLogin/uplCode";
/**
* 请求摄像头参数
*/
public static String URi_device_DevJoinGood_GetCameraInfo = URiBase + "/device/DevJoinGood/GetCameraInfo";
/**
* 消息通知
*/
public static String Uri_device_DevOrder_Devclient_MessgaeNotice = URiBase + "/device/DevClient/MessageNotice";
/**
* 删除消息
*/
public static String Uri_device_DevOrder_Devclient_DeleteMessage = URiBase + "/device/DevClient/DeleteMessage";
/**
* 标为已读消息
*/
public static String Uri_device_DevOrder_Devclient_ReadMessage = URiBase + "/device/DevClient/ReadMessage";
/**
* 我的客户(筛选)
*/
public static String Uri_device_DevMark_myselfVisitor = URiBase + "/device/DevMark/myselfVisitor";
/**
* 引流客户(筛选)
*/
public static String Uri_device_DevFission_fissionClient = URiBase + "/device/DevFission/fissionClient";
/**
* 云推荐列表
*/
public static String Uri_device_DevFission_wxcloundinfo = URiBase + "/device/DevFission/WxCloudInfo";
/**
* 设计师推荐列表
*/
public static String Uri_device_DevTool_designerList = URiBase + "/device/DevTool/designerList";
/**
* 转介 -- 批量转介 -- 选择转介客户 （跟踪中、已流失、已成交客户）
*/
public static String Uri_device_DevRefer_myTrackCustomer = URiBase + "/device/DevRefer/myTrackCustomer";
/**
* 老带新列表
*/
public static String Uri_device_DevTool_ldxList = URiBase + "/device/DevTool/ldxList";
/**
* 转介 -- 推荐客户
*/
public static String Uri_device_DevRefer_RoundVidInfo = URiBase + "/device/DevRefer/roundVidInfo";
/**
* 云推荐 -- 开通
*/
public static String Uri_device_DevFission_wxptOpen = URiBase + "/device/DevFission/wxptOpen";
/**
* 某条标为已读消息
*/
public static String Uri_device_DevOrder_Devclient_OneReadMessage = URiBase + "/device/DevClient/OneReadMessage";
/**
* 获取登录者所有店铺信息
*/
public static String Uri_device_DevOperat_getStore = URiBase + "/device/DevOperat/getStore";
/**
* 获取店铺的员工名称
*/
public static String Uri_device_DevPersonOperat_getPersonal = URiBase + "/device/DevPersonOperat/getPersonal";
/**
* 店铺运营各项指标信息
*/
public static String Uri_device_DevOperat_getOperatIndices = URiBase + "/device/DevOperat/getOperatIndices";
/**
* 个人业务指标
*/
public static String Uri_device_DevPersonOperat_getPerTarget = URiBase + "/device/DevPersonOperat/getPerTarget";
/**
* 分享业务指标
*/
public static String Uri_device_DevPersonOperat_getForword = URiBase + "/device/DevJoinGood/getForword";
/**
* 分享总结统计
*/
public static String Uri_device_DevPersonOperat_getData = URiBase + "/device/DevJoinGood/shareData";
/**
* 1.2.5版本获取标签问题和打标内容
*/
public static String Uri_device_DevMark_getMarkQuestions = URiBase + "/device/DevMark/getMarkQuestions";
/**
* 补打上传头像
*/
public static String Uri_device_DevMark_updateHeadImg = URiBase + "/device/DevMark/updateHeadImg";
/**
* jc修改visitor_id后，返回正确的访客id
*/
public static String Uri_device_DevMark_trueVisitor = URiBase + "/device/DevMark/trueVisitor";
/**
* 我的客户跟踪历史
*/
public static String URi_device_DevMark_trackhistory = URiBase + "/device/DevMark/trackhistory";
/**
* 惜客指数详情
*/
public static String URi_device_DevPerManager_xikeInfo = URiBase + "/device/DevPerManager/xikeInfo";
/**
* 分配列表
*/
public static String URi_device_AppCustomer_fpList = URiBase + "/device/AppCustomer/fpList";
/**
* 客户列表
*/
public static String URi_device_AppCustomer_customerList = URiBase + "/device/AppCustomer/customerList";
/**
* 成交列表
*/
public static String URi_device_AppCustomer_orderList = URiBase + "/device/AppCustomer/orderList";
/**
* 客户分配
*/
public static String URi_device_AppCustomer_customerFPList = URiBase + "/device/AppCustomer/customerFPList";
/**
* 客户详情
*/
public static String URi_device_AppCustomer_customerDetail = URiBase + "/device/AppCustomer/customerDetail";
/**
* 确认分配
*/
public static String URi_device_AppCustomer_sureFP = URiBase + "/device/AppCustomer/sureFP";
/**
* 行业
*/
public static String URi_device_AppCustomer_industry = URiBase + "/device/AppCustomer/industry";
}

375
app/src/main/java/com/fenghoo/seven/okgonet/NetApi.java Normal file
View File

@@ -0,0 +1,375 @@
package com.fenghoo.seven.okgonet;
import com.lzy.okgo.OkGo;
import com.lzy.okgo.cache.CacheMode;
import com.lzy.okgo.convert.StringConvert;
import com.lzy.okgo.model.Response;
import com.lzy.okrx2.adapter.ObservableResponse;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.annotations.NonNull;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;
public class NetApi {
/**
* 惜客指数详情
*/
public Observable<Response> xikeInfo(final String uid) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_DevPerManager_xikeInfo)//
.params("uid", uid)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 分配列表
*/
public Observable<Response> fpList(final String uid, final String search) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_fpList)//
.params("uid", uid)
.params("search", search)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 客户列表
*/
public Observable<Response> customerList(final String uid, final String search) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_customerList)//
.params("uid", uid)
.params("search", search)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 成交列表
*/
public Observable<Response> orderList(final String uid, final String search) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_orderList)//
.params("uid", uid)
.params("search", search)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 客户分配
*/
public Observable<Response> customerFPList(final String uid) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_customerFPList)//
.params("uid", uid)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 客户详情
*/
public Observable<Response> customerDetail(final String customer_id) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_customerDetail)//
.params("customer_id", customer_id)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 确认分配device/AppCustomer/sureFP
*/
public Observable<Response> sureFP(final String uid, final String content) {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_sureFP)//
.params("uid", uid)
.params("content", content)
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
/**
* 行业
*/
public Observable<Response> industry() {
return new Observable<Response>() {
@Override
public void subscribe(final Observer<Response> observer) {
OkGo.<String>post(HttpConstants.URi_device_AppCustomer_industry)//
.converter(new StringConvert())//
.cacheMode(CacheMode.NO_CACHE) //无缓存模式 CacheMode.NO_CACHE
.adapt(new ObservableResponse<String>())//
.subscribeOn(Schedulers.io())//
.observeOn(AndroidSchedulers.mainThread())//
.subscribe(new io.reactivex.Observer<Response<String>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
// addDisposable(d);
}
@Override
public void onNext(@NonNull Response<String> response) {
observer.onNext(response);
}
@Override
public void onError(@NonNull Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
}
};
}
}

59
app/src/main/java/com/fenghoo/seven/okgonet/Observable.java Normal file
View File

@@ -0,0 +1,59 @@
package com.fenghoo.seven.okgonet;
//定义一个动作
public abstract class Observable<T> {
public abstract void subscribe(Observer<T> observer);
public <R> Observable<R> map(final Func1<T,R> func1){
final Observable<T> source=this;
return new Observable<R>() {
@Override
public void subscribe(final Observer<R> observer) {
source.subscribe(new Observer<T>() {
@Override
public void onNext(T t) {
R r=func1.call(t);
observer.onNext(r);
}
@Override
public void onError(Exception e) {
observer.onError(e);
}
});
}
};
}
public <R> Observable<R> flatMap(final Func1<T, Observable<R>> func1) {
final Observable<T> source=this;
return new Observable<R>() {
@Override
public void subscribe(final Observer<R> observer) {
source.subscribe(new Observer<T>() {
@Override
public void onNext(T t) {
final Observable<R> call = func1.call(t);
call.subscribe(new Observer<R>() {
@Override
public void onNext(R r) {
observer.onNext(r);
}
@Override
public void onError(Exception e) {
observer.onError(e);
}
});
}
@Override
public void onError(Exception e) {
}
});
}
};
}
}

6
app/src/main/java/com/fenghoo/seven/okgonet/Observer.java Normal file
View File

@@ -0,0 +1,6 @@
package com.fenghoo.seven.okgonet;
public interface Observer<T> {
void onNext(T t);
void onError(Exception e);
}