在dispose()中执行前先判断是否已经 被isDispose()

README.md

@@ -21,6 +21,7 @@ Gradle:
 ```
 
 ## 说明
+v1.0.3 在dispose()中执行前先判断是否已经 被isDispose()    见WebSocketSubscriber.kt  -> void dispose()  // 2022 05 13
 v1.0.2 在dispose()中手动close webSocket
 
 v1.0.1 版本移除调试代码

websocket/build.gradle

@@ -102,7 +102,7 @@ task generateSourcesJar(type: Jar) {
     from android.sourceSets.main.java.srcDirs
     classifier 'sources'
 }
-def versionName = '1.0.2'
+def versionName = '1.0.3'
 
 def SNAPSHOT_REPOSITORY_URL = "https://hub.zmcms.cn/repository/maven-snapshots/"
 def RELEASE_REPOSITORY_URL = "https://hub.zmcms.cn/repository/maven-releases/"

websocket/src/main/java/com/dhh/websocket/WebSocketSubscriber.java

@@ -7,7 +7,6 @@ import okhttp3.WebSocket;
 import okio.ByteString;
 
 /**
- *
  * @author dhh
  * @date 2017/10/24
  * <p>
@@ -19,7 +18,8 @@ import okio.ByteString;
 public abstract class WebSocketSubscriber implements Observer<WebSocketInfo> {
     private boolean hasOpened;
     protected Disposable disposable;
-    private WebSocket mWebSocket ;
+    private WebSocket mWebSocket;
+
     @Override
     public final void onNext(@NonNull WebSocketInfo webSocketInfo) {
         if (webSocketInfo.isOnOpen()) {
@@ -64,10 +64,10 @@ public abstract class WebSocketSubscriber implements Observer<WebSocketInfo> {
     }
 
     public final void dispose() {
-        if (disposable != null) {
+        if (disposable != null && !disposable.isDisposed()) {
             disposable.dispose();
         }
-        if (mWebSocket!=null){
+        if (mWebSocket != null) {
             mWebSocket.close(3000, "close WebSocket");
         }
     }