Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement
Sign In

@cosmjs/stream

Package Overview
Dependencies
Maintainers
2
Versions
125
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@cosmjs/stream - npm Package Compare versions

Comparing version
0.36.1
to
0.36.2-0
+2
-2
build/promise.js

@@ -51,4 +51,4 @@ "use strict";

complete: () => {
reject(`Stream completed before all events could be collected. ` +
`Collected ${events.length}, expected ${count}`);
reject(new Error(`Stream completed before all events could be collected. ` +
`Collected ${events.length}, expected ${count}`));
},

@@ -55,0 +55,0 @@ error: (error) => {

@@ -1,1 +0,1 @@

{"version":3,"file":"promise.js","sourceRoot":"","sources":["../src/promise.ts"],"names":[],"mappings":";;AAKA,0CAmBC;AAQD,sCA4BC;AAOD,gCAEC;AArED,qCAA2C;AAE3C;;GAEG;AACH,SAAgB,eAAe,CAAI,OAA6B;IAC9D,MAAM,QAAQ,GAAgB;QAC5B,KAAK,EAAE,CAAC,QAAQ,EAAE,EAAE;YAClB,mEAAmE;YACnE,OAAO;iBACJ,IAAI,CAAC,CAAC,QAAQ,EAAE,EAAE;gBACjB,KAAK,MAAM,OAAO,IAAI,QAAQ,EAAE,CAAC;oBAC/B,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBACzB,CAAC;gBACD,QAAQ,CAAC,QAAQ,EAAE,CAAC;YACtB,CAAC,CAAC;iBACD,KAAK,CAAC,CAAC,KAAK,EAAE,EAAE;gBACf,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;YACxB,CAAC,CAAC,CAAC;QACP,CAAC;QACD,IAAI,EAAE,GAAG,EAAE,GAAE,CAAC;KACf,CAAC;IAEF,OAAO,gBAAM,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;AACjC,CAAC;AAED;;;;;GAKG;AACI,KAAK,UAAU,aAAa,CAAI,MAAiB,EAAE,KAAa;IACrE,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QACnD,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YAChB,OAAO,CAAC,EAAE,CAAC,CAAC;YACZ,OAAO;QACT,CAAC;QAED,MAAM,MAAM,GAAG,IAAI,KAAK,EAAK,CAAC;QAC9B,uDAAuD;QACvD,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,SAAS,CAAC;YAC3B,IAAI,EAAE,CAAC,KAAK,EAAE,EAAE;gBACd,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;gBAEnB,IAAI,MAAM,CAAC,MAAM,KAAK,KAAK,EAAE,CAAC;oBAC5B,OAAO,CAAC,MAAM,CAAC,CAAC;gBAClB,CAAC;YACH,CAAC;YACD,QAAQ,EAAE,GAAG,EAAE;gBACb,MAAM,CACJ,yDAAyD;oBACvD,aAAa,MAAM,CAAC,MAAM,cAAc,KAAK,EAAE,CAClD,CAAC;YACJ,CAAC;YACD,KAAK,EAAE,CAAC,KAAK,EAAE,EAAE;gBACf,MAAM,CAAC,KAAK,CAAC,CAAC;YAChB,CAAC;SACF,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;AACL,CAAC;AAED;;;;GAIG;AACI,KAAK,UAAU,UAAU,CAAI,MAAiB;IACnD,OAAO,CAAC,MAAM,aAAa,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;AAC7C,CAAC"}
{"version":3,"file":"promise.js","sourceRoot":"","sources":["../src/promise.ts"],"names":[],"mappings":";;AAKA,0CAmBC;AAQD,sCA8BC;AAOD,gCAEC;AAvED,qCAA2C;AAE3C;;GAEG;AACH,SAAgB,eAAe,CAAI,OAA6B;IAC9D,MAAM,QAAQ,GAAgB;QAC5B,KAAK,EAAE,CAAC,QAAQ,EAAE,EAAE;YAClB,mEAAmE;YACnE,OAAO;iBACJ,IAAI,CAAC,CAAC,QAAQ,EAAE,EAAE;gBACjB,KAAK,MAAM,OAAO,IAAI,QAAQ,EAAE,CAAC;oBAC/B,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;gBACzB,CAAC;gBACD,QAAQ,CAAC,QAAQ,EAAE,CAAC;YACtB,CAAC,CAAC;iBACD,KAAK,CAAC,CAAC,KAAK,EAAE,EAAE;gBACf,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;YACxB,CAAC,CAAC,CAAC;QACP,CAAC;QACD,IAAI,EAAE,GAAG,EAAE,GAAE,CAAC;KACf,CAAC;IAEF,OAAO,gBAAM,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;AACjC,CAAC;AAED;;;;;GAKG;AACI,KAAK,UAAU,aAAa,CAAI,MAAiB,EAAE,KAAa;IACrE,OAAO,IAAI,OAAO,CAAe,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;QACnD,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YAChB,OAAO,CAAC,EAAE,CAAC,CAAC;YACZ,OAAO;QACT,CAAC;QAED,MAAM,MAAM,GAAG,IAAI,KAAK,EAAK,CAAC;QAC9B,uDAAuD;QACvD,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,SAAS,CAAC;YAC3B,IAAI,EAAE,CAAC,KAAK,EAAE,EAAE;gBACd,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;gBAEnB,IAAI,MAAM,CAAC,MAAM,KAAK,KAAK,EAAE,CAAC;oBAC5B,OAAO,CAAC,MAAM,CAAC,CAAC;gBAClB,CAAC;YACH,CAAC;YACD,QAAQ,EAAE,GAAG,EAAE;gBACb,MAAM,CACJ,IAAI,KAAK,CACP,yDAAyD;oBACvD,aAAa,MAAM,CAAC,MAAM,cAAc,KAAK,EAAE,CAClD,CACF,CAAC;YACJ,CAAC;YACD,KAAK,EAAE,CAAC,KAAK,EAAE,EAAE;gBACf,MAAM,CAAC,KAAK,CAAC,CAAC;YAChB,CAAC;SACF,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;AACL,CAAC;AAED;;;;GAIG;AACI,KAAK,UAAU,UAAU,CAAI,MAAiB;IACnD,OAAO,CAAC,MAAM,aAAa,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;AAC7C,CAAC"}

@@ -42,3 +42,3 @@ "use strict";

subscription.unsubscribe();
reject("Update stream completed without expected value");
reject(new Error("Update stream completed without expected value"));
},

@@ -45,0 +45,0 @@ error: (error) => {

@@ -1,1 +0,1 @@

{"version":3,"file":"valueandupdates.js","sourceRoot":"","sources":["../src/valueandupdates.ts"],"names":[],"mappings":";;;AAAA,qCAAuC;AAMvC;;;;GAIG;AACH,MAAa,eAAe;IACV,OAAO,CAAkB;IAEzC,IAAW,KAAK;QACd,OAAO,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC;IAC7B,CAAC;IAEgB,QAAQ,CAA0B;IAEnD,YAAmB,QAAiC;QAClD,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;QACzB,IAAI,CAAC,OAAO,GAAG,sBAAY,CAAC,gBAAgB,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IAC9D,CAAC;IAED;;;;;OAKG;IACI,KAAK,CAAC,OAAO,CAAC,MAA6B;QAChD,MAAM,oBAAoB,GACxB,OAAO,MAAM,KAAK,UAAU,CAAC,CAAC,CAAE,MAA4B,CAAC,CAAC,CAAC,CAAC,KAAQ,EAAW,EAAE,CAAC,KAAK,KAAK,MAAM,CAAC;QAEzG,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACrC,MAAM,YAAY,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC;gBAC1C,IAAI,EAAE,CAAC,QAAQ,EAAE,EAAE;oBACjB,IAAI,oBAAoB,CAAC,QAAQ,CAAC,EAAE,CAAC;wBACnC,OAAO,CAAC,QAAQ,CAAC,CAAC;wBAElB,2DAA2D;wBAC3D,+CAA+C;wBAC/C,UAAU,CAAC,GAAG,EAAE;4BACd,YAAY,CAAC,WAAW,EAAE,CAAC;wBAC7B,CAAC,EAAE,CAAC,CAAC,CAAC;oBACR,CAAC;gBACH,CAAC;gBACD,QAAQ,EAAE,GAAG,EAAE;oBACb,YAAY,CAAC,WAAW,EAAE,CAAC;oBAC3B,MAAM,CAAC,gDAAgD,CAAC,CAAC;gBAC3D,CAAC;gBACD,KAAK,EAAE,CAAC,KAAK,EAAE,EAAE;oBACf,MAAM,CAAC,KAAK,CAAC,CAAC;gBAChB,CAAC;aACF,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;CACF;AA/CD,0CA+CC"}
{"version":3,"file":"valueandupdates.js","sourceRoot":"","sources":["../src/valueandupdates.ts"],"names":[],"mappings":";;;AAAA,qCAAuC;AAMvC;;;;GAIG;AACH,MAAa,eAAe;IACV,OAAO,CAAkB;IAEzC,IAAW,KAAK;QACd,OAAO,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC;IAC7B,CAAC;IAEgB,QAAQ,CAA0B;IAEnD,YAAmB,QAAiC;QAClD,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;QACzB,IAAI,CAAC,OAAO,GAAG,sBAAY,CAAC,gBAAgB,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IAC9D,CAAC;IAED;;;;;OAKG;IACI,KAAK,CAAC,OAAO,CAAC,MAA6B;QAChD,MAAM,oBAAoB,GACxB,OAAO,MAAM,KAAK,UAAU,CAAC,CAAC,CAAE,MAA4B,CAAC,CAAC,CAAC,CAAC,KAAQ,EAAW,EAAE,CAAC,KAAK,KAAK,MAAM,CAAC;QAEzG,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACrC,MAAM,YAAY,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC;gBAC1C,IAAI,EAAE,CAAC,QAAQ,EAAE,EAAE;oBACjB,IAAI,oBAAoB,CAAC,QAAQ,CAAC,EAAE,CAAC;wBACnC,OAAO,CAAC,QAAQ,CAAC,CAAC;wBAElB,2DAA2D;wBAC3D,+CAA+C;wBAC/C,UAAU,CAAC,GAAG,EAAE;4BACd,YAAY,CAAC,WAAW,EAAE,CAAC;wBAC7B,CAAC,EAAE,CAAC,CAAC,CAAC;oBACR,CAAC;gBACH,CAAC;gBACD,QAAQ,EAAE,GAAG,EAAE;oBACb,YAAY,CAAC,WAAW,EAAE,CAAC;oBAC3B,MAAM,CAAC,IAAI,KAAK,CAAC,gDAAgD,CAAC,CAAC,CAAC;gBACtE,CAAC;gBACD,KAAK,EAAE,CAAC,KAAK,EAAE,EAAE;oBACf,MAAM,CAAC,KAAK,CAAC,CAAC;gBAChB,CAAC;aACF,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;CACF;AA/CD,0CA+CC"}
{
"name": "@cosmjs/stream",
"version": "0.36.1",
"version": "0.36.2-0",
"description": "Utility functions for producing and consuming streams",

@@ -11,4 +11,6 @@ "contributors": [

"license": "Apache-2.0",
"main": "build/index.js",
"types": "build/index.d.ts",
"exports": {
"types": "./build/index.d.ts",
"default": "./build/index.js"
},
"files": [

@@ -29,3 +31,3 @@ "build/",

"scripts": {
"docs": "typedoc --options typedoc.cjs",
"docs": "typedoc",
"format": "prettier --write --log-level warn \"./src/**/*.ts\"",

@@ -39,3 +41,3 @@ "format-text": "prettier --write \"./*.md\"",

"build": "rm -rf ./build && tsc",
"build-or-skip": "[ -n \"$SKIP_BUILD\" ] || yarn build",
"build-or-skip": "[ -n \"${SKIP_BUILD:-}\" ] || yarn build",
"pack-web": "yarn build-or-skip && webpack --mode development --config webpack.web.config.cjs"

@@ -61,4 +63,4 @@ },

"karma-jasmine-html-reporter": "^1.5.4",
"nyc": "^15.1.0",
"prettier": "^3.5.3",
"nyc": "^17.1.0",
"prettier": "^3.6.2",
"ses": "^1.13.0",

@@ -70,3 +72,4 @@ "source-map-support": "^0.5.19",

"webpack-cli": "^4.6.0"
}
},
"stableVersion": "0.36.1"
}
# @cosmjs/stream
![typescript](https://img.shields.io/npm/types/@cosmjs/stream.svg)
[![npm version](https://img.shields.io/npm/v/@cosmjs/stream.svg)](https://www.npmjs.com/package/@cosmjs/stream)
[![license](https://img.shields.io/npm/l/@cosmjs/stream.svg)](https://github.com/cosmos/cosmjs/blob/v0.35.0/LICENSE)
![minimum node version](https://img.shields.io/node/v/@cosmjs/stream.svg)
![minified size](https://img.shields.io/bundlephobia/min/@cosmjs/stream.svg)
![monthly downloads](https://img.shields.io/npm/dm/@cosmjs/stream.svg)

@@ -5,0 +10,0 @@ @cosmjs/stream are some helper methods and classes to help with stream