feat: add connect event

README.md

@@ -78,6 +78,7 @@ See the complete command list: [https://redis.io/commands](https://redis.io/comm
 
 + `message`: See [Pub/Sub](#Pub/Sub)
 + `error`: Emitted when a connection error occurs.
++ `connect`: Emitted when a socket connection is successfully established.
 
 ### Pub/Sub
 

doc/zh-CN.md

@@ -61,6 +61,7 @@ client.GET(...args);
 
 + `message`: 查看 [Pub/Sub](#Pub/Sub)。
 + `error`: 发生连接错误时触发。
++ `connect`: 成功建立socket连接时触发。
 
 ### Pub/Sub
 

src/client/baseClient.ts

@@ -41,11 +41,12 @@ export abstract class BaseClient {
             this.queue.forEach(elem => {
                 this.socket.write(elem);
             });
+            this.handleConnect?.();
         });
         this.socket.on('data', (data) => {
             this.parser.decodeReply(data);
         });
-        this.socket.on('error', (err) => { this.handleError(err); });
+        this.socket.on('error', err => { this.handleError(err); });
         this.socket.on('close', (hadError) => {
             /**
              * In addition to actively disconnecting the client or server, 
@@ -65,6 +66,7 @@ export abstract class BaseClient {
         }, 100);
     }
 
+    private handleConnect?: () => void;
     private handleError(err: Error): void {
         console.error(err + '');
     }
@@ -102,14 +104,16 @@ export abstract class BaseClient {
         });
     }
 
-    public on(event: 'message' | 'error', listener: (data: unknown) => void): void {
+    public on(event: 'message' | 'error' | 'connect', listener: (data?: unknown) => void): void {
         switch (event) {
             case 'message':
                 this.parser.on(event, listener);
                 break;
             case 'error':
                 this.handleError = listener;
                 break;
+            case 'connect':
+                this.handleConnect = listener;
         }
     }
 }