From 68d7250b95451272aaa7cf359fd68b98d91b4d56 Mon Sep 17 00:00:00 2001
From: liugl <liugl@sinata.cn>
Date: 星期二, 11 八月 2020 11:31:41 +0800
Subject: [PATCH] 1：乘客付款不播报，下单播报延时，3断网后重连接不了单
---
rxnetty/src/main/java/cn/sinata/rxnetty/NettyClient.java | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/rxnetty/src/main/java/cn/sinata/rxnetty/NettyClient.java b/rxnetty/src/main/java/cn/sinata/rxnetty/NettyClient.java
index 5a7a4ec..fa753db 100644
--- a/rxnetty/src/main/java/cn/sinata/rxnetty/NettyClient.java
+++ b/rxnetty/src/main/java/cn/sinata/rxnetty/NettyClient.java
@@ -4,8 +4,14 @@
import android.content.Context;
import android.content.Intent;
import android.os.Build;
+import android.os.Handler;
+import android.widget.Toast;
import java.util.ArrayList;
+
+import cn.sinata.rxnetty.Cache.CacheUtil;
+
+import static android.os.Looper.getMainLooper;
/**
* 使用的是rxjava1。而不是rxjava2。所以尽量不要在主项目中使用rxjava1相关类。以免交叉。不好维护修改。
@@ -19,6 +25,7 @@
private OnSendListener sendListener;
private OnConnectListener connectListener;
private OnCheckListener onCheckListener;
+ private OnCheckListenerNull onCheckListenerNull;
public void init(Context context,String server,int port) {
init(context,server,port,false);
@@ -29,6 +36,10 @@
Config.SOCKET_SERVER = server;
Config.SOCKET_PORT = port;
Config.isStartForeground= isStartForeground;
+ }
+
+ public Context getmContext() {
+ return mContext;
}
public OnConnectListener getConnectListener() {
@@ -90,6 +101,9 @@
void setOnCheckListener(OnCheckListener listener) {
this.onCheckListener = listener;
}
+ void setOnCheckNullListener(OnCheckListenerNull listener){
+ this.onCheckListenerNull = listener;
+ }
/**
* 发送消息给服务器
@@ -109,6 +123,12 @@
onCheckListener.doCheck();
}
}
+ public void checkNettyStateNull() {
+ if (onCheckListenerNull != null) {
+ onCheckListenerNull.doCheck();
+ }
+ }
+
public void startService() {
if (mContext == null) {
--
Gitblit v1.7.1