@effection/subscription - npm Package Compare versions

Comparing version 2.0.0-preview.2-94f9d4d to 2.0.0-preview.2-b660659

dist/subscribable.d.ts

@@ -12,3 +12,3 @@ import { Operation, Task } from '@effection/core';
     expect(): Operation<T>;
-    forEach(visit: (value: T) => Operation<void>): Operation<TReturn>;
+    forEach(visit: (value: T) => (Operation<void> | void)): Operation<TReturn>;
     collect(): Operation<Iterator<T, TReturn>>;
@@ -15,0 +15,0 @@ toArray(): Operation<T[]>;

dist/subscription.cjs.development.js

@@ -311,3 +311,7 @@ 'use strict';
           } else {
-            yield visit(result.value);
+            var operation = visit(result.value);
+
+            if (operation) {
+              yield operation;
+            }
           }
@@ -314,0 +318,0 @@ }

dist/subscription.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";function n(n,r){var t,e,u=(t=[],e=[],{push:function(n){var r=t.pop();r?r(n):e.push(n)},pop:function(){return function(n){return function(r){e.length?r(e.shift()):(n.ensure((function(){var n=t.indexOf(r);n>-1&&t.splice(n,1)})),t.push(r))}}}}),o=function(n){u.push({done:!1,value:n})};return n.spawn((function*(){try{var n=yield r((function(n){return o(n)}));u.push({done:!0,value:n})}finally{o=function(n){throw function(n){var r=new Error("tried to publish a value: "+n+" on an already finished subscription");return r.name="TypeError",r}(n)}}})),{next:function(){return function*(){return yield u.pop()}}}}var r=Symbol.for("effection/iterable");function t(n){return function(r){if("object"==typeof r&&"object"==typeof n){var e=r;return Object.entries(n).every((function(n){var r=n[0];return t(n[1])(e[r])}))}return r===n}}var e=function(){function e(n){this.iterator=n}e.create=function(r,t){return new e(n(r,t))},e.of=function(n,t){return new e(t[r](n))};var u=e.prototype;return u.filter=function(n){var r=this.iterator;return new e({next:function(){return function*(){for(;;){var t=yield r.next();if(t.done)return t;if(n(t.value))return t}}}})},u.match=function(n){return this.filter(t(n))},u.map=function(n){var r=this.iterator;return new e({next:function(){return function*(){for(;;){var t=yield r.next();return t.done?t:{done:!1,value:n(t.value)}}}}})},u.first=function(){var n=this.iterator;return function*(){var r=yield n.next();return r.done?void 0:r.value}},u.expect=function(){var n=this.iterator;return function*(){var r=yield n.next();if(r.done)throw new Error("expected subscription to contain a value");return r.value}},u.forEach=function(n){var r=this.iterator;return function*(){for(;;){var t=yield r.next();if(t.done)return t.value;yield n(t.value)}}},u.next=function(){return this.iterator.next()},e}();exports.Subscription=e,exports.SymbolOperationIterable=r,exports.createOperationIterator=n,exports.createSubscribable=function e(u){var o,i,f=function(r){return n(r,u)},c=(o={filter:function(n){return e((function(r){return c.forEach((function(t){return function*(){n(t)&&r(t)}}))}))},match:function(n){return c.filter(t(n))},map:function(n){return e((function(r){return c.forEach((function(t){return function*(){r(n(t))}}))}))},first:function(){return function*(n){var r=f(n),t=yield r.next();return t.done?void 0:t.value}},expect:function(){return function*(n){var r=f(n),t=yield r.next();if(t.done)throw new Error("expected subscription to contain a value");return t.value}},forEach:function(n){return function*(r){for(var t=f(r);;){var e=yield t.next();if(e.done)return e.value;yield n(e.value)}}},collect:function(){return function*(){var n=[],r=yield c.forEach((function(r){return function*(){n.push(r)}}));return function*(){return yield*n,r}()}},toArray:function(){return function*(){return Array.from(yield c.collect())}},subscribe:function(n){return f(n)}},(i={})[r]=i[r]||{},i[r].get=function(){return f},function(n,r){for(var t in r)(o=r[t]).configurable=o.enumerable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(n,t,o);if(Object.getOwnPropertySymbols)for(var e=Object.getOwnPropertySymbols(r),u=0;u<e.length;u++){var o,i=e[u];(o=r[i]).configurable=o.enumerable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(n,i,o)}}(o,i),o);return c},exports.subscribe=function(n,r){return e.of(n,r)};
+"use strict";function n(n,r){var t,e,u=(t=[],e=[],{push:function(n){var r=t.pop();r?r(n):e.push(n)},pop:function(){return function(n){return function(r){e.length?r(e.shift()):(n.ensure((function(){var n=t.indexOf(r);n>-1&&t.splice(n,1)})),t.push(r))}}}}),o=function(n){u.push({done:!1,value:n})};return n.spawn((function*(){try{var n=yield r((function(n){return o(n)}));u.push({done:!0,value:n})}finally{o=function(n){throw function(n){var r=new Error("tried to publish a value: "+n+" on an already finished subscription");return r.name="TypeError",r}(n)}}})),{next:function(){return function*(){return yield u.pop()}}}}var r=Symbol.for("effection/iterable");function t(n){return function(r){if("object"==typeof r&&"object"==typeof n){var e=r;return Object.entries(n).every((function(n){var r=n[0];return t(n[1])(e[r])}))}return r===n}}var e=function(){function e(n){this.iterator=n}e.create=function(r,t){return new e(n(r,t))},e.of=function(n,t){return new e(t[r](n))};var u=e.prototype;return u.filter=function(n){var r=this.iterator;return new e({next:function(){return function*(){for(;;){var t=yield r.next();if(t.done)return t;if(n(t.value))return t}}}})},u.match=function(n){return this.filter(t(n))},u.map=function(n){var r=this.iterator;return new e({next:function(){return function*(){for(;;){var t=yield r.next();return t.done?t:{done:!1,value:n(t.value)}}}}})},u.first=function(){var n=this.iterator;return function*(){var r=yield n.next();return r.done?void 0:r.value}},u.expect=function(){var n=this.iterator;return function*(){var r=yield n.next();if(r.done)throw new Error("expected subscription to contain a value");return r.value}},u.forEach=function(n){var r=this.iterator;return function*(){for(;;){var t=yield r.next();if(t.done)return t.value;yield n(t.value)}}},u.next=function(){return this.iterator.next()},e}();exports.Subscription=e,exports.SymbolOperationIterable=r,exports.createOperationIterator=n,exports.createSubscribable=function e(u){var o,i,f=function(r){return n(r,u)},c=(o={filter:function(n){return e((function(r){return c.forEach((function(t){return function*(){n(t)&&r(t)}}))}))},match:function(n){return c.filter(t(n))},map:function(n){return e((function(r){return c.forEach((function(t){return function*(){r(n(t))}}))}))},first:function(){return function*(n){var r=f(n),t=yield r.next();return t.done?void 0:t.value}},expect:function(){return function*(n){var r=f(n),t=yield r.next();if(t.done)throw new Error("expected subscription to contain a value");return t.value}},forEach:function(n){return function*(r){for(var t=f(r);;){var e=yield t.next();if(e.done)return e.value;var u=n(e.value);u&&(yield u)}}},collect:function(){return function*(){var n=[],r=yield c.forEach((function(r){return function*(){n.push(r)}}));return function*(){return yield*n,r}()}},toArray:function(){return function*(){return Array.from(yield c.collect())}},subscribe:function(n){return f(n)}},(i={})[r]=i[r]||{},i[r].get=function(){return f},function(n,r){for(var t in r)(o=r[t]).configurable=o.enumerable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(n,t,o);if(Object.getOwnPropertySymbols)for(var e=Object.getOwnPropertySymbols(r),u=0;u<e.length;u++){var o,i=e[u];(o=r[i]).configurable=o.enumerable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(n,i,o)}}(o,i),o);return c},exports.subscribe=function(n,r){return e.of(n,r)};
 //# sourceMappingURL=subscription.cjs.production.min.js.map

dist/subscription.esm.js

@@ -309,3 +309,7 @@ function createQueue() {
           } else {
-            yield visit(result.value);
+            var operation = visit(result.value);
+
+            if (operation) {
+              yield operation;
+            }
           }
@@ -312,0 +316,0 @@ }

package.json

 {
   "name": "@effection/subscription",
-  "version": "2.0.0-preview.2-94f9d4d",
+  "version": "2.0.0-preview.2-b660659",
   "description": "Effection Subscriptions",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

src/subscribable.ts

@@ -15,3 +15,3 @@ import { Operation, Task } from '@effection/core';
   expect(): Operation<T>;
-  forEach(visit: (value: T) => Operation<void>): Operation<TReturn>;
+  forEach(visit: (value: T) => (Operation<void> | void)): Operation<TReturn>;
   collect(): Operation<Iterator<T, TReturn>>;
@@ -72,3 +72,3 @@ toArray(): Operation<T[]>;
 
-    forEach(visit: (value: T) => Operation<void>): Operation<TReturn> {
+    forEach(visit: (value: T) => (Operation<void> | void)): Operation<TReturn> {
       return function*(task) {
@@ -81,3 +81,6 @@ let iterator = iterable(task);
           } else {
-            yield visit(result.value);
+            let operation = visit(result.value);
+            if(operation) {
+              yield operation;
+            }
           }
@@ -84,0 +87,0 @@ }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

95601

increased by0.82%

Lines of code

1061

increased by0.86%

No dependency changes