		{
		"name": "@thi.ng/rstream",
		"version": "0.1.1",
		"version": "0.2.1",
		"description": "Reactive multi-tap streams & transformation pipeline constructs",
		"main": "index.js",
		"typings": "index.d.ts",
		"main": "./index.js",
		"typings": "./index.d.ts",
		"repository": "https://github.com/thi-ng/rstream",
		"author": "Karsten Schmidt",
		"author": "Karsten Schmidt <k+npm@thi.ng>",
		"license": "Apache-2.0",
		"scripts": {
		"build": "rm -rf build && tsc --declaration && cp package.json *.md build",
		"test": "tsc -p test && mocha build.test/test/*.js",
		"clean": "rm -rf build build.test doc node_modules && yarn install",
		"build": "yarn run clean && tsc --declaration",
		"test": "yarn run clean && tsc -p test && mocha build/test/*.js",
		"clean": "rm -rf .js .d.ts build doc from subs utils",
		"pub": "yarn run build && (cd build && yarn publish --access public)"
		},
		"devDependencies": {
		"mocha": "^4.0.1",
		"ts-loader": "^3.2.0",
		"@types/mocha": "^2.2.46",
		"@types/node": "^9.3.0",
		"mocha": "^5.0.0",
		"ts-loader": "^3.3.1",
		"typedoc": "^0.9.0",
		@@ -24,8 +26,9 @@ "typescript": "^2.6.2",
		"dependencies": {
		"@thi.ng/api": "^1.1.1",
		"@thi.ng/csp": "^0.3.0",
		"@thi.ng/dcons": "^0.1.3",
		"@thi.ng/transducers": "^0.10.1"
		"@thi.ng/api": "^1.2.1",
		"@thi.ng/csp": "^0.3.1",
		"@thi.ng/dcons": "^0.1.4",
		"@thi.ng/transducers": "^0.11.1"
		},
		"keywords": [
		"ES6",
		"events",
		@@ -36,6 +39,9 @@ "pipeline",
		"subscription",
		"transducer",
		"transformation",
		"transducer",
		"typescript"
		]
		}
		],
		"publishConfig": {
		"access": "public"
		}
		}

README.md

stream-merge.js

		@@ -8,3 +8,3 @@ "use strict";
		constructor(...args) {
		let id = is_string_1.isString(args[args.length - 1]) ? args.pop() : `merge-${subscription_1.Subscription.NEXT_ID++}`, src, xform;
		let id = is_string_1.isString(args[args.length - 1]) ? args.pop() : `streammerge-${subscription_1.Subscription.NEXT_ID++}`, src, xform;
		switch (args.length) {
		@@ -11,0 +11,0 @@ case 2:

stream.js

		@@ -6,3 +6,3 @@ "use strict";
		constructor(src, id) {
		super(null, null, null, id \|\| `observable-${Stream.NEXT_ID++}`);
		super(null, null, null, id \|\| `stream-${Stream.NEXT_ID++}`);
		this.src = src;
		@@ -9,0 +9,0 @@ }

subs/bisect.js

		"use strict";
		Object.defineProperty(exports, "__esModule", { value: true });
		const subscription_1 = require("../subscription");
		// TODO wrap A & B and attach as children? else, how to propagate teardown?
		function bisect(pred, a, b) {
		@@ -5,0 +6,0 @@ return new subscription_1.Subscription({

subs/resolve.js

		@@ -7,3 +7,3 @@ "use strict";
		constructor(id) {
		super(null, null, null, id);
		super(null, null, null, id \|\| `resolve-${subscription_1.Subscription.NEXT_ID++}`);
		this.outstanding = 0;
		@@ -10,0 +10,0 @@ }

subs/trace.d.ts

		import { ISubscriber } from "../api";
		export declare function trace(prefix: any): ISubscriber<any>;
		export declare function trace(prefix?: any): ISubscriber<any>;

@thi.ng/rstream - npm Package Compare versions

New alerts