@cosmjs/stream
Advanced tools
+2
-2
@@ -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"} |
+11
-8
| { | ||
| "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" | ||
| } |
+5
-0
| # @cosmjs/stream | ||
|  | ||
| [](https://www.npmjs.com/package/@cosmjs/stream) | ||
| [](https://github.com/cosmos/cosmjs/blob/v0.35.0/LICENSE) | ||
|  | ||
|  | ||
|  | ||
@@ -5,0 +10,0 @@ @cosmjs/stream are some helper methods and classes to help with stream |
30591
1.7%18
38.46%