@effection/subscription - npm Package Compare versions

Comparing version 2.0.0-preview.2-40ae4ab to 2.0.0-preview.2-6cc2387

dist/subscription.cjs.development.js

@@ -311,7 +311,3 @@ 'use strict';
           } else {
-            var thing = visit(result.value);
-
-            if (thing) {
-              yield thing;
-            }
+            visit(result.value);
           }
@@ -318,0 +314,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;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)};
+"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;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)};
 //# sourceMappingURL=subscription.cjs.production.min.js.map

dist/subscription.esm.js

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

package.json

 {
   "name": "@effection/subscription",
-  "version": "2.0.0-preview.2-40ae4ab",
+  "version": "2.0.0-preview.2-6cc2387",
   "description": "Effection Subscriptions",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

src/subscribable.ts

@@ -71,3 +71,3 @@ import { Operation, Task } from '@effection/core';
 
-    forEach(visit: (value: T) => Operation<void> | void): Operation<TReturn> {
+    forEach(visit: (value: T) => Operation<void>): Operation<TReturn> {
       return function*(task) {
@@ -80,6 +80,3 @@ let iterator = iterable(task);
           } else {
-            let thing = visit(result.value);
-            if(thing) {
-              yield thing;
-            }
+            visit(result.value);
           }
@@ -86,0 +83,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

Worsened metrics

Total package byte prevSize

94785

decreased by-0.71%

Lines of code

1052

decreased by-0.85%

No dependency changes