@effection/subscription - npm Package Compare versions

Comparing version 2.0.0-preview.2-b660659 to 2.0.0-preview.3-698bf2f

CHANGELOG.md

 # @effection/subscription
 
+## 2.0.0-preview.3
+
+### Minor Changes
+
+- 3ca4cd4: Add `createSubscribable` and `Subscribable` interface
+
+### Patch Changes
+
+- Updated dependencies [bdedf68]
+- Updated dependencies [2bf5ef4]
+  - @effection/core@2.0.0-preview.3
+
 ## 2.0.0-preview.2
@@ -4,0 +16,0 @@

dist/index.d.ts

@@ -6,3 +6,3 @@ export { createOperationIterator } from './create-operation-iterator';
 export { Subscription } from './subscription';
-export { createSubscribable, Subscribable } from './subscribable';
+export { createStream, Stream } from './stream';
 export { subscribe } from './subscribe';

dist/subscription.cjs.development.js

@@ -246,3 +246,3 @@ 'use strict';
 
-function createSubscribable(callback) {
+function createStream(callback) {
   var _subscribable, _mutatorMap;
@@ -256,3 +256,3 @@
     filter: function filter(predicate) {
-      return createSubscribable(function (publish) {
+      return createStream(function (publish) {
         return subscribable.forEach(function (value) {
@@ -271,3 +271,3 @@ return function* () {
     map: function map(mapper) {
-      return createSubscribable(function (publish) {
+      return createStream(function (publish) {
         return subscribable.forEach(function (value) {
@@ -358,4 +358,4 @@ return function* () {
 exports.createOperationIterator = createOperationIterator;
-exports.createSubscribable = createSubscribable;
+exports.createStream = createStream;
 exports.subscribe = subscribe;
 //# sourceMappingURL=subscription.cjs.development.js.map

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.createStream=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

@@ -244,3 +244,3 @@ function createQueue() {
 
-function createSubscribable(callback) {
+function createStream(callback) {
   var _subscribable, _mutatorMap;
@@ -254,3 +254,3 @@
     filter: function filter(predicate) {
-      return createSubscribable(function (publish) {
+      return createStream(function (publish) {
         return subscribable.forEach(function (value) {
@@ -269,3 +269,3 @@ return function* () {
     map: function map(mapper) {
-      return createSubscribable(function (publish) {
+      return createStream(function (publish) {
         return subscribable.forEach(function (value) {
@@ -353,3 +353,3 @@ return function* () {
 
-export { Subscription, SymbolOperationIterable, createOperationIterator, createSubscribable, subscribe };
+export { Subscription, SymbolOperationIterable, createOperationIterator, createStream, subscribe };
 //# sourceMappingURL=subscription.esm.js.map

package.json

 {
   "name": "@effection/subscription",
-  "version": "2.0.0-preview.2-b660659",
+  "version": "2.0.0-preview.3-698bf2f",
   "description": "Effection Subscriptions",
@@ -23,5 +23,6 @@ "main": "dist/index.js",
   "dependencies": {
-    "@effection/core": "^2.0.0-preview.2"
+    "@effection/core": "^2.0.0-preview.3"
   },
   "devDependencies": {
+    "@effection/mocha": "2.0.0-preview.2",
     "@frontside/tsconfig": "0.0.1",
@@ -28,0 +29,0 @@ "@types/mocha": "^8.0.3",

src/index.ts

@@ -6,3 +6,3 @@ export { createOperationIterator } from './create-operation-iterator';
 export { Subscription } from './subscription';
-export { createSubscribable, Subscribable } from './subscribable';
+export { createStream, Stream } from './stream';
 export { subscribe } from './subscribe';

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

95425

decreased by-0.18%

Dev dependency count

8

increased by14.29%

Dependency changes

• Updated@effection/core@^2.0.0-preview.3