Add option to set request timeout

Author: Mitch528

android/src/main/java/com/reactnativegrpc/GrpcModule.java

@@ -176,6 +176,12 @@ private ClientCall startGrpcCall(int callId, int clientId, String path, MethodDe
 
     CallOptions callOptions = CallOptions.DEFAULT;
 
+    if (settings.hasKey("requestTimeout")) {
+      int callTimeout = settings.getInt("requestTimeout");
+
+      callOptions = callOptions.withDeadlineAfter(callTimeout, TimeUnit.MILLISECONDS);
+    }
+
     if (settings.hasKey("compressionName")) {
       callOptions = callOptions.withCompression(settings.getString("compressionName"));
     }

example/ios/Podfile.lock

@@ -259,7 +259,7 @@ PODS:
   - React-jsinspector (0.70.6)
   - React-logger (0.70.6):
     - glog
-  - react-native-grpc (1.0.0-8):
+  - react-native-grpc (1.0.0-9):
     - gRPC-Swift
     - React-Core
   - React-perflogger (0.70.6)
@@ -637,7 +637,7 @@ SPEC CHECKSUMS:
   React-jsiexecutor: b4a65947391c658450151275aa406f2b8263178f
   React-jsinspector: 60769e5a0a6d4b32294a2456077f59d0266f9a8b
   React-logger: 1623c216abaa88974afce404dc8f479406bbc3a0
-  react-native-grpc: 8c905356969a7a4ba96e96c04331e6b8de1addee
+  react-native-grpc: 268c75d05f16e874a814f7a820b3a3e9f1ef7311
   React-perflogger: 8c79399b0500a30ee8152d0f9f11beae7fc36595
   React-RCTActionSheet: 7316773acabb374642b926c19aef1c115df5c466
   React-RCTAnimation: 5341e288375451297057391227f691d9b2326c3d
@@ -668,4 +668,4 @@ SPEC CHECKSUMS:
 
 PODFILE CHECKSUM: dade9e439d349a55615e971fb13a399b0ba1f887
 
-COCOAPODS: 1.11.3
+COCOAPODS: 1.12.0

ios/RNGrpc.swift

@@ -311,11 +311,16 @@ class RNGrpc: RCTEventEmitter {
 
     private func getCallOptionsWithHeaders(id: Int, headers: HPACKHeaders) throws -> CallOptions {
         var encoding: ClientMessageEncoding = .disabled
+        var timeLimit: TimeLimit = .none
 
         guard let (options, _) = self.connections[id] else {
             throw GrpcError.missingConnection
         }
 
+        if let callTimeout = options["requestTimeout"] as? Int64 {
+            timeLimit = .timeout(.seconds(callTimeout))
+        }
+
         if let enabled = options["compression"] as? NSNumber, enabled.boolValue {
             let compressionAlgorithm: [CompressionAlgorithm]
 
@@ -343,7 +348,7 @@ class RNGrpc: RCTEventEmitter {
             )
         }
 
-        return CallOptions(customMetadata: headers, messageEncoding: encoding)
+        return CallOptions(customMetadata: headers, timeLimit: timeLimit, messageEncoding: encoding)
     }
 
     private func closeConnection(id: Int) throws {

src/types.ts

@@ -12,6 +12,7 @@ export type GrpcClientSettings = {
   keepalive?: boolean;
   keepaliveInterval?: number;
   keepaliveTimeout?: number;
+  requestTimeout?: number;
 };
 
 export interface GrpcServerInputStream {