@dorsi/callbag-bundle - npm Package Compare versions

Comparing version 0.1.0 to 0.2.0

dist/bundle.cjs.js

@@ -885,2 +885,25 @@ 'use strict';
 
+function makeSubject() {
+  let sinks = [];
+  return (type, data) => {
+    if (type === 0) {
+      const sink = data;
+      sinks.push(sink);
+      sink(0, t => {
+        if (t === 2) {
+          const i = sinks.indexOf(sink);
+          if (i > -1) sinks.splice(i, 1);
+        }
+      });
+    } else {
+      const zinkz = sinks.slice(0);
+
+      for (let i = 0, n = zinkz.length, sink; i < n; i++) {
+        sink = zinkz[i];
+        if (sinks.indexOf(sink) > -1) sink(type, data);
+      }
+    }
+  };
+}
+
 exports.forEach = forEach;
@@ -907,1 +930,2 @@ exports.fromObs = fromObs;
 exports.sampleWhen = sampleWhen;
+exports.makeSubject = makeSubject;

dist/bundle.esm.js

@@ -881,2 +881,25 @@ /**
 
-export { forEach, fromObs, fromIter, fromEvent, fromPromise, interval, map, scan, flatten, take, skip, filter, merge, concat, combine, share, pipe, observe, of, sample, sampleWhen };
+function makeSubject() {
+  let sinks = [];
+  return (type, data) => {
+    if (type === 0) {
+      const sink = data;
+      sinks.push(sink);
+      sink(0, t => {
+        if (t === 2) {
+          const i = sinks.indexOf(sink);
+          if (i > -1) sinks.splice(i, 1);
+        }
+      });
+    } else {
+      const zinkz = sinks.slice(0);
+
+      for (let i = 0, n = zinkz.length, sink; i < n; i++) {
+        sink = zinkz[i];
+        if (sinks.indexOf(sink) > -1) sink(type, data);
+      }
+    }
+  };
+}
+
+export { forEach, fromObs, fromIter, fromEvent, fromPromise, interval, map, scan, flatten, take, skip, filter, merge, concat, combine, share, pipe, observe, of, sample, sampleWhen, makeSubject };

dist/bundle.umd.js

@@ -887,2 +887,25 @@ (function (global, factory) {
 
+function makeSubject() {
+  let sinks = [];
+  return (type, data) => {
+    if (type === 0) {
+      const sink = data;
+      sinks.push(sink);
+      sink(0, t => {
+        if (t === 2) {
+          const i = sinks.indexOf(sink);
+          if (i > -1) sinks.splice(i, 1);
+        }
+      });
+    } else {
+      const zinkz = sinks.slice(0);
+
+      for (let i = 0, n = zinkz.length, sink; i < n; i++) {
+        sink = zinkz[i];
+        if (sinks.indexOf(sink) > -1) sink(type, data);
+      }
+    }
+  };
+}
+
 exports.forEach = forEach;
@@ -909,2 +932,3 @@ exports.fromObs = fromObs;
 exports.sampleWhen = sampleWhen;
+exports.makeSubject = makeSubject;
 
@@ -911,0 +935,0 @@ Object.defineProperty(exports, '__esModule', { value: true });

index.js

@@ -22,1 +22,2 @@ export { default as forEach } from "callbag-for-each"
 export { default as sampleWhen } from "callbag-sample-when"
+export { default as makeSubject } from "callbag-subject"

package.json

 {
 	"name": "@dorsi/callbag-bundle",
-	"version": "0.1.0",
+	"version": "0.2.0",
 	"description": "A collection of callbag modules exported as es modules",
@@ -23,9 +23,2 @@ "repository": {
 		"babel-jest": "^23.2.0",
-		"jest": "^23.3.0",
-		"lebab": "^2.7.7",
-		"regenerator-runtime": "^0.12.0",
-		"rollup": "^0.55.5",
-		"rollup-plugin-babel": "^4.0.0-beta.7",
-		"rollup-plugin-node-resolve": "^3.0.2",
-		"rollup-plugin-resolve": "0.0.1-predev.1",
 		"callbag": "^1.1.0",
@@ -52,4 +45,12 @@ "callbag-combine": "^1.1.0",
 		"callbag-skip": "^1.0.0",
-		"callbag-take": "^1.0.0"
+		"callbag-subject": "^1.0.2",
+		"callbag-take": "^1.0.0",
+		"jest": "^23.3.0",
+		"lebab": "^2.7.7",
+		"regenerator-runtime": "^0.12.0",
+		"rollup": "^0.55.5",
+		"rollup-plugin-babel": "^4.0.0-beta.7",
+		"rollup-plugin-node-resolve": "^3.0.2",
+		"rollup-plugin-resolve": "0.0.1-predev.1"
 	}
 }

No alert changes

Improved metrics

Total package byte prevSize

72740

increased by2.36%

Lines of code

2595

increased by2.61%

Worsened metrics

Dev dependency count

34

increased by3.03%

No dependency changes