Launch Week Day 3: Introducing Organization Notifications in Socket.Learn More
Socket
Book a DemoSign in
Socket

@aws-sdk/chunked-stream-reader-node

Package Overview
Dependencies
Maintainers
4
Versions
78
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@aws-sdk/chunked-stream-reader-node - npm Package Compare versions

Comparing version
0.1.0-preview.3
to
0.1.0-preview.4
+8
-9
build/index.js
"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"}

@@ -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 @@

{
"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",

{
"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",