@aws-sdk/chunked-stream-reader-node
Advanced tools
+8
-9
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| function streamReader(stream, onChunk, chunkSize // 1 MiB | ||
| function streamReader(stream, onChunk, chunkSize = 1048576 // 1 MiB | ||
| ) { | ||
| if (chunkSize === void 0) { chunkSize = 1048576; } | ||
| return new Promise(function (resolve, reject) { | ||
| var temporaryBuffer; | ||
| return new Promise((resolve, reject) => { | ||
| let temporaryBuffer; | ||
| stream.on("error", reject); | ||
| stream.on("end", function () { | ||
| stream.on("end", () => { | ||
| if (temporaryBuffer && temporaryBuffer.byteLength) { | ||
| for (var i = 0; i < temporaryBuffer.byteLength; i += chunkSize) { | ||
| for (let i = 0; i < temporaryBuffer.byteLength; i += chunkSize) { | ||
| onChunk(temporaryBuffer.subarray(i, Math.min(i + chunkSize, temporaryBuffer.byteLength))); | ||
@@ -19,3 +18,3 @@ } | ||
| }); | ||
| stream.on("data", function (chunk) { | ||
| stream.on("data", (chunk) => { | ||
| if (!temporaryBuffer) { | ||
@@ -27,3 +26,3 @@ temporaryBuffer = chunk; | ||
| } | ||
| var pointer = 0; | ||
| let pointer = 0; | ||
| while (temporaryBuffer.byteLength - pointer >= chunkSize) { | ||
@@ -41,3 +40,3 @@ onChunk(temporaryBuffer.subarray(pointer, pointer + chunkSize)); | ||
| function mergeUint8Arrays(a, b) { | ||
| var result = new Uint8Array(a.byteLength + b.byteLength); | ||
| const result = new Uint8Array(a.byteLength + b.byteLength); | ||
| result.set(a); | ||
@@ -44,0 +43,0 @@ result.set(b, a.byteLength); |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AACA,SAAgB,YAAY,CAC1B,MAAgB,EAChB,OAAoC,EACpC,SAA2B,CAAC,QAAQ;;IAApC,0BAAA,EAAA,mBAA2B;IAE3B,OAAO,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;QACjC,IAAI,eAAuC,CAAC;QAE5C,MAAM,CAAC,EAAE,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;QAC3B,MAAM,CAAC,EAAE,CAAC,KAAK,EAAE;YACf,IAAI,eAAe,IAAI,eAAe,CAAC,UAAU,EAAE;gBACjD,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,eAAe,CAAC,UAAU,EAAE,CAAC,IAAI,SAAS,EAAE;oBAC9D,OAAO,CACL,eAAe,CAAC,QAAQ,CACtB,CAAC,EACD,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,SAAS,EAAE,eAAe,CAAC,UAAU,CAAC,CACpD,CACF,CAAC;iBACH;gBACD,4BAA4B;gBAC5B,eAAe,GAAG,KAAK,CAAC,CAAC;aAC1B;YACD,OAAO,EAAE,CAAC;QACZ,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,KAAa;YAC9B,IAAI,CAAC,eAAe,EAAE;gBACpB,eAAe,GAAG,KAAK,CAAC;aACzB;iBAAM;gBACL,eAAe,GAAG,gBAAgB,CAAC,eAAe,EAAE,KAAK,CAAC,CAAC;aAC5D;YAED,IAAI,OAAO,GAAG,CAAC,CAAC;YAChB,OAAO,eAAe,CAAC,UAAU,GAAG,OAAO,IAAI,SAAS,EAAE;gBACxD,OAAO,CAAC,eAAe,CAAC,QAAQ,CAAC,OAAO,EAAE,OAAO,GAAG,SAAS,CAAC,CAAC,CAAC;gBAChE,OAAO,IAAI,SAAS,CAAC;aACtB;YACD,eAAe,GAAG,eAAe,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;QACtD,CAAC,CAAC,CAAC;QAEH,iCAAiC;QACjC,MAAM,CAAC,MAAM,EAAE,CAAC;IAClB,CAAC,CAAC,CAAC;AACL,CAAC;AA1CD,oCA0CC;AAED,SAAS,gBAAgB,CAAC,CAAa,EAAE,CAAa;IACpD,IAAM,MAAM,GAAG,IAAI,UAAU,CAAC,CAAC,CAAC,UAAU,GAAG,CAAC,CAAC,UAAU,CAAC,CAAC;IAC3D,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;IACd,MAAM,CAAC,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,UAAU,CAAC,CAAC;IAC5B,OAAO,MAAM,CAAC;AAChB,CAAC"} | ||
| {"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;AACA,SAAgB,YAAY,CAC1B,MAAgB,EAChB,OAAoC,EACpC,YAAoB,OAAO,CAAC,QAAQ;;IAEpC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QACrC,IAAI,eAAuC,CAAC;QAE5C,MAAM,CAAC,EAAE,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;QAC3B,MAAM,CAAC,EAAE,CAAC,KAAK,EAAE,GAAG,EAAE;YACpB,IAAI,eAAe,IAAI,eAAe,CAAC,UAAU,EAAE;gBACjD,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,eAAe,CAAC,UAAU,EAAE,CAAC,IAAI,SAAS,EAAE;oBAC9D,OAAO,CACL,eAAe,CAAC,QAAQ,CACtB,CAAC,EACD,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,SAAS,EAAE,eAAe,CAAC,UAAU,CAAC,CACpD,CACF,CAAC;iBACH;gBACD,4BAA4B;gBAC5B,eAAe,GAAG,KAAK,CAAC,CAAC;aAC1B;YACD,OAAO,EAAE,CAAC;QACZ,CAAC,CAAC,CAAC;QACH,MAAM,CAAC,EAAE,CAAC,MAAM,EAAE,CAAC,KAAa,EAAE,EAAE;YAClC,IAAI,CAAC,eAAe,EAAE;gBACpB,eAAe,GAAG,KAAK,CAAC;aACzB;iBAAM;gBACL,eAAe,GAAG,gBAAgB,CAAC,eAAe,EAAE,KAAK,CAAC,CAAC;aAC5D;YAED,IAAI,OAAO,GAAG,CAAC,CAAC;YAChB,OAAO,eAAe,CAAC,UAAU,GAAG,OAAO,IAAI,SAAS,EAAE;gBACxD,OAAO,CAAC,eAAe,CAAC,QAAQ,CAAC,OAAO,EAAE,OAAO,GAAG,SAAS,CAAC,CAAC,CAAC;gBAChE,OAAO,IAAI,SAAS,CAAC;aACtB;YACD,eAAe,GAAG,eAAe,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;QACtD,CAAC,CAAC,CAAC;QAEH,iCAAiC;QACjC,MAAM,CAAC,MAAM,EAAE,CAAC;IAClB,CAAC,CAAC,CAAC;AACL,CAAC;AA1CD,oCA0CC;AAED,SAAS,gBAAgB,CAAC,CAAa,EAAE,CAAa;IACpD,MAAM,MAAM,GAAG,IAAI,UAAU,CAAC,CAAC,CAAC,UAAU,GAAG,CAAC,CAAC,UAAU,CAAC,CAAC;IAC3D,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;IACd,MAAM,CAAC,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,UAAU,CAAC,CAAC;IAC5B,OAAO,MAAM,CAAC;AAChB,CAAC"} |
+25
-0
@@ -6,2 +6,27 @@ # Change Log | ||
| # [0.1.0-preview.4](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/chunked-stream-reader-node@0.1.0-preview.1...@aws-sdk/chunked-stream-reader-node@0.1.0-preview.4) (2019-09-19) | ||
| # 0.3.0 (2019-09-09) | ||
| ### Features | ||
| * commit all clients ([#324](https://github.com/aws/aws-sdk-js-v3/issues/324)) ([cb268ed](https://github.com/aws/aws-sdk-js-v3/commit/cb268ed)) | ||
| # 0.2.0 (2019-07-12) | ||
| ### Features | ||
| * add npm badges for individual packages ([#251](https://github.com/aws/aws-sdk-js-v3/issues/251)) ([8adc10c](https://github.com/aws/aws-sdk-js-v3/commit/8adc10c)) | ||
| * update jest v20 to v24 ([#243](https://github.com/aws/aws-sdk-js-v3/issues/243)) ([1e156ab](https://github.com/aws/aws-sdk-js-v3/commit/1e156ab)) | ||
| # [0.1.0-preview.3](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/chunked-stream-reader-node@0.1.0-preview.1...@aws-sdk/chunked-stream-reader-node@0.1.0-preview.3) (2019-09-09) | ||
@@ -8,0 +33,0 @@ |
+1
-1
| { | ||
| "name": "@aws-sdk/chunked-stream-reader-node", | ||
| "version": "0.1.0-preview.3", | ||
| "version": "0.1.0-preview.4", | ||
| "scripts": { | ||
@@ -5,0 +5,0 @@ "prepublishOnly": "tsc", |
+1
-8
| { | ||
| "compilerOptions": { | ||
| "target": "es5", | ||
| "target": "es2017", | ||
| "module": "commonjs", | ||
@@ -11,9 +11,2 @@ "declaration": true, | ||
| "noEmitHelpers": true, | ||
| "lib": [ | ||
| "es5", | ||
| "es2015.promise", | ||
| "es2015.collection", | ||
| "es2015.iterable", | ||
| "es2015.symbol.wellknown" | ||
| ], | ||
| "rootDir": "./src", | ||
@@ -20,0 +13,0 @@ "outDir": "./build", |
18327
3.03%64
-11.11%