⚠️NativeEventEmmiter increases progressively bug

Author: 1uokun

README.md

@@ -93,6 +93,11 @@ ws.onclose = (e) => {
 ws.onerror = (e) => {
     console.log("onerror",e)
 };
+
+// add listen connecting event
+ws.onconnecting = () => {
+    console.log("onconnecting")
+}
 ```
 2. add heartbeat
 ```javascript

index.js

@@ -1,7 +1,6 @@
 import {NativeModules} from 'react-native'
 const {WebSocketModule} = NativeModules;
 
-let timeout;
 let settings = {
     /** The number of milliseconds to delay before attempting to reconnect. */
     reconnectInterval: 1000,
@@ -41,6 +40,8 @@ class ReconnectingWebSocket extends WebSocket{
         this.reconnectAttempts = 0;
 
         this.protocols = protocols;
+
+        this.timeout = null;
     }
 
     _unregisterEvents(){
@@ -59,25 +60,10 @@ class ReconnectingWebSocket extends WebSocket{
                     return;
                 }
 
-                clearTimeout(timeout);
+                this.timeout && clearTimeout(this.timeout);
                 this.reconnectAttempts = 0
             }),
 
-            /** @Override onclose **/
-            this._eventEmitter.addListener('websocketClosed', ev => {
-                if (ev.id !== this._socketId) {
-                    return;
-                }
-
-                let _timeout = this.reconnectInterval * Math.pow(this.reconnectDecay, this.reconnectAttempts);
-
-                clearTimeout(timeout);
-                setTimeout(()=>{
-                    this.reconnectAttempts++;
-                    this.reconnect()
-                }, _timeout > this.maxReconnectInterval ? this.maxReconnectInterval : _timeout);
-            }),
-
             /** @Override onerror **/
             this._eventEmitter.addListener('websocketFailed', ev => {
                 if (ev.id !== this._socketId) {
@@ -86,8 +72,8 @@ class ReconnectingWebSocket extends WebSocket{
 
                 let _timeout = this.reconnectInterval * Math.pow(this.reconnectDecay, this.reconnectAttempts);
 
-                clearTimeout(timeout);
-                setTimeout(()=>{
+                this.timeout && clearTimeout(this.timeout);
+                this.timeout = setTimeout(()=>{
                     this.reconnectAttempts++;
                     this.reconnect()
                 }, _timeout > this.maxReconnectInterval ? this.maxReconnectInterval : _timeout);
@@ -99,7 +85,7 @@ class ReconnectingWebSocket extends WebSocket{
         if (this.maxReconnectAttempts && this.reconnectAttempts > this.maxReconnectAttempts) {
             return;
         }
-        setTimeout(()=>{
+        this.timeout = setTimeout(()=>{
 
             WebSocketModule.connect(
                 this.url,
@@ -108,10 +94,6 @@ class ReconnectingWebSocket extends WebSocket{
                 this._socketId,
             );
 
-            timeout=setTimeout(()=>{
-                this.reconnect()
-            },this.timeoutInterval)
-
         }, this.reconnectInterval);
 
     }