Add Android increment HTTP support

Author: wkh237

src/android/src/main/java/com/RNFetchBlob/RNFetchBlobConfig.java

@@ -19,6 +19,7 @@ public class RNFetchBlobConfig {
     public String mime;
     public Boolean auto;
     public long timeout = 60000;
+    public Boolean increment = false;
     public ReadableArray binaryContentTypes = null;
 
     RNFetchBlobConfig(ReadableMap options) {
@@ -35,6 +36,7 @@ public class RNFetchBlobConfig {
             this.binaryContentTypes = options.getArray("binaryContentTypes");
         this.key = options.hasKey("key") ? options.getString("key") : null;
         this.mime = options.hasKey("contentType") ? options.getString("contentType") : null;
+        this.increment = options.hasKey("increment") ? options.getBoolean("increment") : false;
         this.auto = options.hasKey("auto") ? options.getBoolean("auto") : false;
         if(options.hasKey("timeout")) {
             this.timeout = options.getInt("timeout");

src/android/src/main/java/com/RNFetchBlob/RNFetchBlobReq.java

@@ -292,7 +292,8 @@ public Response intercept(Chain chain) throws IOException {
                                 extended = new RNFetchBlobDefaultResp(
                                         RNFetchBlob.RCTContext,
                                         taskId,
-                                        originalResponse.body());
+                                        originalResponse.body(),
+                                        options.increment);
                                 break;
                             case FileStorage:
                                 extended = new RNFetchBlobFileResp(
@@ -305,7 +306,8 @@ public Response intercept(Chain chain) throws IOException {
                                 extended = new RNFetchBlobDefaultResp(
                                         RNFetchBlob.RCTContext,
                                         taskId,
-                                        originalResponse.body());
+                                        originalResponse.body(),
+                                        options.increment);
                                 break;
                         }
                         return originalResponse.newBuilder().body(extended).build();

src/android/src/main/java/com/RNFetchBlob/Response/RNFetchBlobDefaultResp.java

@@ -9,6 +9,7 @@
 import com.facebook.react.modules.core.DeviceEventManagerModule;
 
 import java.io.IOException;
+import java.nio.charset.Charset;
 
 import okhttp3.Call;
 import okhttp3.Callback;
@@ -30,11 +31,13 @@ public class RNFetchBlobDefaultResp extends ResponseBody {
     String mTaskId;
     ReactApplicationContext rctContext;
     ResponseBody originalBody;
+    boolean isIncrement = false;
 
-    public RNFetchBlobDefaultResp(ReactApplicationContext ctx, String taskId, ResponseBody body) {
+    public RNFetchBlobDefaultResp(ReactApplicationContext ctx, String taskId, ResponseBody body, boolean isIncrement) {
         this.rctContext = ctx;
         this.mTaskId = taskId;
         this.originalBody = body;
+        this.isIncrement = isIncrement;
     }
 
     @Override
@@ -71,6 +74,13 @@ public long read(Buffer sink, long byteCount) throws IOException {
                 args.putString("taskId", mTaskId);
                 args.putString("written", String.valueOf(bytesRead));
                 args.putString("total", String.valueOf(contentLength()));
+                if(isIncrement) {
+                    args.putString("chunk", sink.readString(Charset.defaultCharset()));
+                }
+                else {
+                    args.putString("chunk", "");
+                }
+
                 rctContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
                         .emit(RNFetchBlobConst.EVENT_PROGRESS, args);
             }