Merge pull request #5 from krishnafkh/develop

Added option to set Compression on the gRPC client - android

Author: Mitch528

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

@@ -30,6 +30,8 @@ public class GrpcModule extends ReactContextBaseJavaModule {
 
   private String host;
   private boolean isInsecure = false;
+  private boolean withCompression = false;
+  private String compressorName = "";
   private Integer responseSizeLimit = null;
   private ManagedChannel managedChannel = null;
 
@@ -63,6 +65,12 @@ public void setInsecure(boolean insecure) {
     this.isInsecure = insecure;
   }
 
+  @ReactMethod
+  public void setCompression(Boolean enable, String compressorName) {
+    this.withCompression = enable;
+    this.compressorName = compressorName;
+  }
+
   @ReactMethod
   public void setResponseSizeLimit(int limit) {
     this.responseSizeLimit = limit;
@@ -161,6 +169,10 @@ private ClientCall startGrpcCall(int id, String path, MethodDescriptor.MethodTyp
 
     CallOptions callOptions = CallOptions.DEFAULT;
 
+    if (!this.compressorName.isEmpty()) {
+      callOptions = callOptions.withCompression(this.compressorName);
+    }
+
     ClientCall call = this.getManagedChannel().newCall(descriptor, callOptions);
 
     call.start(new ClientCall.Listener() {
@@ -246,6 +258,10 @@ public void onClose(Status status, Metadata trailers) {
       }
     }, headersMetadata);
 
+    if (this.withCompression) {
+      call.setMessageCompression(true);
+    }
+
     return call;
   }
 

src/client.ts

@@ -18,6 +18,7 @@ type GrpcType = {
   getIsInsecure: () => Promise<boolean>;
   setHost(host: string): void;
   setInsecure(insecure: boolean): void;
+  setCompression(enable: boolean, compressorName: string): void;
   setResponseSizeLimit(limitInBytes: number): void;
   unaryCall(
     id: number,
@@ -178,6 +179,9 @@ export class GrpcClient {
   setInsecure(insecure: boolean): void {
     Grpc.setInsecure(insecure);
   }
+  setCompression(enable: boolean, compressorName: string): void {
+    Grpc.setCompression(enable, compressorName);
+  }
   setResponseSizeLimit(limitInBytes: number): void {
     Grpc.setResponseSizeLimit(limitInBytes);
   }