@-0/spool
Advanced tools
Comparing version 0.3.0 to 0.3.1
@@ -1,2 +0,2 @@ | ||
import { Subscription, PubSub } from "@thi.ng/rstream"; | ||
import { PubSub, ISubscription } from "@thi.ng/rstream"; | ||
export declare const keys_match: (C: any) => string; | ||
@@ -9,7 +9,7 @@ export declare const processArgs: (acc: any, args: any) => any; | ||
erro: any; | ||
}, O$?: PubSub<any, any>, i?: number) => Promise<any>; | ||
}, O$?: PubSub<any, any, any>, i?: number) => Promise<any>; | ||
export declare const multiplex: (out$: any) => (task_array: any) => any; | ||
export declare const run$: PubSub<any, any>; | ||
export declare const out$: PubSub<any, any>; | ||
export declare const cmd$: Subscription<any, any>; | ||
export declare const task$: Subscription<any, any>; | ||
export declare const cmd$: ISubscription<any, any>; | ||
export declare const task$: ISubscription<any, any>; |
@@ -172,7 +172,13 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
next: x => out$.next(x), | ||
error: console.warn | ||
error: e => { | ||
console.warn(e); | ||
return true; | ||
} | ||
}, { id: "cmd$_stream" }); | ||
export const task$ = run$.subscribeTopic(false, { | ||
next: multiplex(out$), | ||
error: console.warn | ||
error: e => { | ||
console.warn(e); | ||
return true; | ||
} | ||
}, { id: "task$_stream" }); |
import { Subscription } from "@thi.ng/rstream"; | ||
import { CMD_SUB$, CMD_ARGS, CMD_RESO, CMD_ERRO, Command } from "@-0/keys"; | ||
import { Command } from "@-0/keys"; | ||
export declare const log$: Subscription<any, any>; | ||
@@ -4,0 +4,0 @@ export declare const forwardUpstreamCMD$: any; |
@@ -5,3 +5,3 @@ { | ||
"license": "MIT", | ||
"version": "0.3.0", | ||
"version": "0.3.1", | ||
"description": "SPA framework built on top of http://thi.ng/umbrella ecosystem", | ||
@@ -34,37 +34,32 @@ "main": "./lib/index.js", | ||
}, | ||
"dependencies": { | ||
"@-0/keys": "^0.3.3", | ||
"@-0/utils": "^0.3.3" | ||
}, | ||
"peerDependencies": { | ||
"@thi.ng/arrays": "^0.10.1", | ||
"@thi.ng/associative": "5.0.17", | ||
"@thi.ng/atom": "^4.1.27", | ||
"@thi.ng/checks": "^2.8.0", | ||
"@thi.ng/paths": "^4.1.13", | ||
"@thi.ng/transducers": "^7.5.8", | ||
"@thi.ng/rstream": "^5.1.0" | ||
"@thi.ng/paths": "^4.2.7", | ||
"@thi.ng/rstream": "^6.0.8" | ||
}, | ||
"dependencies": { | ||
"@-0/keys": "^0.3.2", | ||
"@-0/utils": "^0.3.2" | ||
}, | ||
"devDependencies": { | ||
"@babel/plugin-transform-modules-commonjs": "^7.12.13", | ||
"@thi.ng/arrays": "^0.10.1", | ||
"@thi.ng/associative": "5.0.17", | ||
"@thi.ng/atom": "^4.1.27", | ||
"@thi.ng/checks": "^2.8.0", | ||
"@thi.ng/paths": "^4.1.13", | ||
"@thi.ng/transducers": "^7.5.8", | ||
"@thi.ng/rstream": "^5.1.0", | ||
"@types/jest": "^26.0.20", | ||
"@types/node": "^14.14.28", | ||
"@typescript-eslint/eslint-plugin": "^4.15.1", | ||
"@typescript-eslint/parser": "^4.15.1", | ||
"@babel/plugin-transform-modules-commonjs": "^7.14.0", | ||
"@thi.ng/arrays": "^0.10.11", | ||
"@thi.ng/associative": "5.2.4", | ||
"@thi.ng/atom": "^4.1.35", | ||
"@thi.ng/checks": "^2.9.6", | ||
"@thi.ng/paths": "^4.2.7", | ||
"@thi.ng/transducers": "^7.7.2", | ||
"@thi.ng/rstream": "^6.0.8", | ||
"@types/jest": "^26.0.23", | ||
"@types/node": "^15.3.0", | ||
"@typescript-eslint/eslint-plugin": "^4.24.0", | ||
"@typescript-eslint/parser": "^4.24.0", | ||
"babel-jest": "^26.6.3", | ||
"better-docs": "^2.3.2", | ||
"cross-env": "^7.0.3", | ||
"eslint": "^7.20.0", | ||
"eslint": "^7.26.0", | ||
"gh-pages": "^3.1.0", | ||
"jest": "^26.6.3", | ||
"prettier": "^2.2.1", | ||
"ts-jest": "^26.5.1", | ||
"typescript": "^4.1.5" | ||
"prettier": "^2.3.0", | ||
"ts-jest": "^26.5.6", | ||
"typescript": "^4.2.4" | ||
}, | ||
@@ -71,0 +66,0 @@ "prettier": { |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
4
289
36462
+ Added@thi.ng/rstream@6.0.21(transitive)
- Removed@thi.ng/api@6.13.6(transitive)
- Removed@thi.ng/arrays@0.10.16(transitive)
- Removed@thi.ng/associative@5.0.17(transitive)
- Removed@thi.ng/rstream@5.1.7(transitive)
- Removedtslib@2.0.1(transitive)
Updated@-0/keys@^0.3.3
Updated@-0/utils@^0.3.3