feat: support connectTimeout

Author: maoweipeng

android/src/main/java/com/asterinet/react/tcpsocket/TcpSocketClient.java

@@ -65,7 +65,8 @@ public void connect(Context context, String address, final Integer port, Readabl
         final int localPort = options.hasKey("localPort") ? options.getInt("localPort") : 0;
         // bind
         socket.bind(new InetSocketAddress(localInetAddress, localPort));
-        socket.connect(new InetSocketAddress(remoteInetAddress, port));
+        final int connectTimeout = options.hasKey("connectTimeout") ? options.getInt("connectTimeout") : 0; 
+        socket.connect(new InetSocketAddress(remoteInetAddress, port), connectTimeout);
         if (socket instanceof SSLSocket) ((SSLSocket) socket).startHandshake();
         startListening();
     }

ios/TcpSocketClient.m

@@ -144,11 +144,12 @@ - (BOOL)connect:(NSString *)host
 
     NSString *localAddress = options[@"localAddress"];
     NSNumber *localPort = options[@"localPort"];
+    int connectTimeout = options[@"connectTimeout"] ? [options[@"connectTimeout"] intValue] / 1000 : -1;
 
     _host = host;
     _connecting = true;
     if (!localAddress && !localPort) {
-        result = [_tcpSocket connectToHost:host onPort:port error:error];
+        result = [_tcpSocket connectToHost:host onPort:port withTimeout:connectTimeout error:error];
     } else {
         NSMutableArray *interface = [NSMutableArray arrayWithCapacity:2];
         [interface addObject:localAddress ? localAddress : @""];
@@ -159,7 +160,7 @@ - (BOOL)connect:(NSString *)host
             [_tcpSocket connectToHost:host
                                onPort:port
                          viaInterface:[interface componentsJoinedByString:@":"]
-                          withTimeout:-1
+                          withTimeout:connectTimeout
                                 error:error];
     }
     if (result && tlsOptions) {

lib/types/Socket.d.ts

@@ -253,6 +253,7 @@ export type ConnectionOptions = {
     tls?: boolean | undefined;
     tlsCheckValidity?: boolean | undefined;
     tlsCert?: any;
+    connectTimeout?: number;
 };
 export type ReadableEvents = {
     pause: () => void;

src/Socket.js

@@ -25,6 +25,7 @@ import { nativeEventEmitter, getNextId } from './Globals';
  * tls?: boolean,
  * tlsCheckValidity?: boolean,
  * tlsCert?: any,
+ * connectTimeout?: number,
  * }} ConnectionOptions
  *
  * @typedef {object} ReadableEvents