|
@@ -281,7 +281,7 @@ class RNFetchBlobBody extends RequestBody{
|
281
|
281
|
*/
|
282
|
282
|
private void pipeStreamToSink(InputStream stream, BufferedSink sink) throws IOException {
|
283
|
283
|
byte[] chunk = new byte[10240];
|
284
|
|
- int totalWritten = 0;
|
|
284
|
+ long totalWritten = 0;
|
285
|
285
|
int read;
|
286
|
286
|
while((read = stream.read(chunk, 0, 10240)) > 0) {
|
287
|
287
|
sink.write(chunk, 0, read);
|
|
@@ -403,7 +403,7 @@ class RNFetchBlobBody extends RequestBody{
|
403
|
403
|
* Emit progress event
|
404
|
404
|
* @param written Integer
|
405
|
405
|
*/
|
406
|
|
- private void emitUploadProgress(int written) {
|
|
406
|
+ private void emitUploadProgress(long written) {
|
407
|
407
|
RNFetchBlobProgressConfig config = RNFetchBlobReq.getReportUploadProgress(mTaskId);
|
408
|
408
|
if(config != null && contentLength != 0 && config.shouldReport((float)written/contentLength)) {
|
409
|
409
|
WritableMap args = Arguments.createMap();
|