@effection/subscription - npm Package Compare versions

Comparing version 0.11.0-6fb5df6 to 0.11.0-70ecf47

dist/index.d.ts

@@ -11,2 +11,2 @@ export { Subscription } from './subscription';
 import { SubscriptionSource } from './subscription-source';
-export declare const forEach: <T, TReturn>(source: SubscriptionSource<T, TReturn>, visit: (value: T) => Operation<void>) => Operation<TReturn>;
+export declare function forEach<T, TReturn>(source: SubscriptionSource<T, TReturn>, visit: (value: T) => Operation<void>): Operation<TReturn>;

dist/subscribable.d.ts

@@ -9,3 +9,3 @@ import { Operation } from 'effection';
 export declare const Subscribable: {
-    from: <T, TReturn>(source: SubscriptionSource<T, TReturn>) => (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>);
+    from<T, TReturn>(source: SubscriptionSource<T, TReturn>): (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").OperationFn<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("effection").Sequence<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>) | (import("effection").Controller<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & PromiseLike<import("./chainable-subscription").ChainableSubscription<T, TReturn>> & import("./chainable-subscribable").ChainableSubscribableMethods<T, TReturn>);
 };

dist/subscription.cjs.development.js

@@ -280,42 +280,13 @@ 'use strict';
 
-function deprecated(message, fn) {
-  var _impl = function impl() {
-    try {
-      throw new Error('trace');
-    } catch (trace) {
-      var _trace$stack$split$sl = trace.stack.split("\n").slice(3, 4),
-          line = _trace$stack$split$sl[0];
-
-      console.warn(message, "\n" + line);
-    }
-
-    _impl = fn;
-
-    for (var _len = arguments.length, args = new Array(_len), _key = 0; _key < _len; _key++) {
-      args[_key] = arguments[_key];
-    }
-
-    return fn.call.apply(fn, [this].concat(args));
-  };
-
-  return function () {
-    var _impl2;
-
-    for (var _len2 = arguments.length, args = new Array(_len2), _key2 = 0; _key2 < _len2; _key2++) {
-      args[_key2] = arguments[_key2];
-    }
-
-    return (_impl2 = _impl).call.apply(_impl2, [this].concat(args));
-  };
-}
-
 var Subscribable = {
-  from: /*#__PURE__*/deprecated('`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead', function (source) {
+  from: function from(source) {
+    console.warn('`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead');
     return subscribe(source);
-  })
+  }
 };
 
-var forEach = /*#__PURE__*/deprecated('`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead', function* forEach(source, visit) {
+function* forEach(source, visit) {
+  console.warn('`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead');
   return yield subscribe(source).forEach(visit);
-});
+}
 
@@ -322,0 +293,0 @@ exports.ChainableSubscription = ChainableSubscription;

dist/subscription.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";var n=require("effection"),r=Symbol.for("Symbol.subscription"),t={next:function(){throw new Error("dummy")}},e=function(){function e(n){this.subscription=n}e.of=function*(i){var u=new e(t);return yield n.resource(u,(function*(){u.subscription=yield function(n){return n[r]?n[r]():n}(i),yield}))},e.wrap=function*(r,i){var u=new e(t);return yield n.resource(u,(function*(){var n=yield r;u.subscription=i(n),yield}))};var i=e.prototype;return i.filter=function(n){var r=this.subscription;return new e({next:function*(){for(;;){var t=yield r.next();if(t.done)return t;if(n(t.value))return t}}})},i.match=function(n){return this.filter(function n(r){return function(t){if("object"==typeof t&&"object"==typeof r){var e=t;return Object.entries(r).every((function(r){var t=r[0];return n(r[1])(e[t])}))}return t===r}}(n))},i.map=function(n){var r=this.subscription;return new e({next:function*(){for(;;){var t=yield r.next();return t.done?t:{done:!1,value:n(t.value)}}}})},i.first=function*(){var n=yield this.subscription.next();return n.done?void 0:n.value},i.expect=function*(){var n=yield this.subscription.next();if(n.done)throw new Error("expected subscription to contain a value");return n.value},i.forEach=function*(n){for(;;){var r=yield this.subscription.next();if(r.done)return r.value;yield n(r.value)}},i.next=function(){return this.subscription.next()},e}();function i(n){var t;return Object.assign(n,((t={})[r]=function*(){return yield n},t.filter=function(r){return i((function*(){return yield e.wrap(n,(function(n){return n.filter(r)}))}))},t.match=function(r){return i((function*(){return yield e.wrap(n,(function(n){return n.match(r)}))}))},t.map=function(r){return i((function*(){return yield e.wrap(n,(function(n){return n.map(r)}))}))},t.first=function*(){return yield(yield n).first()},t.expect=function*(){return yield(yield n).expect()},t.forEach=function*(r){return yield(yield n).forEach(r)},t.next=function*(){return yield(yield n).next()},t))}var u=function(){var n=this;this.waiters=[],this.signal=function(r){var t=n.waiters.pop();t&&t(r)},this.wait=function(){return new Promise((function(r){return n.waiters.push(r)}))}};function o(n){return i((function*(){return yield e.of(n)}))}function c(n,r){var t=function(){try{throw new Error("trace")}catch(r){var e=r.stack.split("\n").slice(3,4),i=e[0];console.warn(n,"\n"+i)}t=r;for(var u=arguments.length,o=new Array(u),c=0;c<u;c++)o[c]=arguments[c];return r.call.apply(r,[this].concat(o))};return function(){for(var n,r=arguments.length,e=new Array(r),i=0;i<r;i++)e[i]=arguments[i];return(n=t).call.apply(n,[this].concat(e))}}var a={from:c("`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead",(function(n){return o(n)}))},s=c("`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead",(function*(n,r){return yield o(n).forEach(r)}));exports.ChainableSubscription=e,exports.Subscribable=a,exports.SymbolSubscribable=r,exports.createSubscription=function(r){return i((function*(){var t=[],i=new u,o=function(n){t.push({done:!1,value:n}),i.signal()};return yield n.resource(new e({next:function(){try{var n=i.wait();return t.length>0&&i.signal(),Promise.resolve(n.then((function(){return t.shift()})))}catch(n){return Promise.reject(n)}}}),(function*(){try{var n=yield r((function(n){return o(n)}));t.push({done:!0,value:n}),i.signal()}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)}}}))}))},exports.forEach=s,exports.subscribe=o;
+"use strict";var n=require("effection"),r=Symbol.for("Symbol.subscription"),e={next:function(){throw new Error("dummy")}},t=function(){function t(n){this.subscription=n}t.of=function*(i){var u=new t(e);return yield n.resource(u,(function*(){u.subscription=yield function(n){return n[r]?n[r]():n}(i),yield}))},t.wrap=function*(r,i){var u=new t(e);return yield n.resource(u,(function*(){var n=yield r;u.subscription=i(n),yield}))};var i=t.prototype;return i.filter=function(n){var r=this.subscription;return new t({next:function*(){for(;;){var e=yield r.next();if(e.done)return e;if(n(e.value))return e}}})},i.match=function(n){return this.filter(function n(r){return function(e){if("object"==typeof e&&"object"==typeof r){var t=e;return Object.entries(r).every((function(r){var e=r[0];return n(r[1])(t[e])}))}return e===r}}(n))},i.map=function(n){var r=this.subscription;return new t({next:function*(){for(;;){var e=yield r.next();return e.done?e:{done:!1,value:n(e.value)}}}})},i.first=function*(){var n=yield this.subscription.next();return n.done?void 0:n.value},i.expect=function*(){var n=yield this.subscription.next();if(n.done)throw new Error("expected subscription to contain a value");return n.value},i.forEach=function*(n){for(;;){var r=yield this.subscription.next();if(r.done)return r.value;yield n(r.value)}},i.next=function(){return this.subscription.next()},t}();function i(n){var e;return Object.assign(n,((e={})[r]=function*(){return yield n},e.filter=function(r){return i((function*(){return yield t.wrap(n,(function(n){return n.filter(r)}))}))},e.match=function(r){return i((function*(){return yield t.wrap(n,(function(n){return n.match(r)}))}))},e.map=function(r){return i((function*(){return yield t.wrap(n,(function(n){return n.map(r)}))}))},e.first=function*(){return yield(yield n).first()},e.expect=function*(){return yield(yield n).expect()},e.forEach=function*(r){return yield(yield n).forEach(r)},e.next=function*(){return yield(yield n).next()},e))}var u=function(){var n=this;this.waiters=[],this.signal=function(r){var e=n.waiters.pop();e&&e(r)},this.wait=function(){return new Promise((function(r){return n.waiters.push(r)}))}};function o(n){return i((function*(){return yield t.of(n)}))}var c={from:function(n){return console.warn("`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead"),o(n)}};exports.ChainableSubscription=t,exports.Subscribable=c,exports.SymbolSubscribable=r,exports.createSubscription=function(r){return i((function*(){var e=[],i=new u,o=function(n){e.push({done:!1,value:n}),i.signal()};return yield n.resource(new t({next:function(){try{var n=i.wait();return e.length>0&&i.signal(),Promise.resolve(n.then((function(){return e.shift()})))}catch(n){return Promise.reject(n)}}}),(function*(){try{var n=yield r((function(n){return o(n)}));e.push({done:!0,value:n}),i.signal()}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)}}}))}))},exports.forEach=function*(n,r){return console.warn("`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead"),yield o(n).forEach(r)},exports.subscribe=o;
 //# sourceMappingURL=subscription.cjs.production.min.js.map

dist/subscription.esm.js

@@ -278,44 +278,15 @@ import { resource } from 'effection';
 
-function deprecated(message, fn) {
-  var _impl = function impl() {
-    try {
-      throw new Error('trace');
-    } catch (trace) {
-      var _trace$stack$split$sl = trace.stack.split("\n").slice(3, 4),
-          line = _trace$stack$split$sl[0];
-
-      console.warn(message, "\n" + line);
-    }
-
-    _impl = fn;
-
-    for (var _len = arguments.length, args = new Array(_len), _key = 0; _key < _len; _key++) {
-      args[_key] = arguments[_key];
-    }
-
-    return fn.call.apply(fn, [this].concat(args));
-  };
-
-  return function () {
-    var _impl2;
-
-    for (var _len2 = arguments.length, args = new Array(_len2), _key2 = 0; _key2 < _len2; _key2++) {
-      args[_key2] = arguments[_key2];
-    }
-
-    return (_impl2 = _impl).call.apply(_impl2, [this].concat(args));
-  };
-}
-
 var Subscribable = {
-  from: /*#__PURE__*/deprecated('`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead', function (source) {
+  from: function from(source) {
+    console.warn('`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead');
     return subscribe(source);
-  })
+  }
 };
 
-var forEach = /*#__PURE__*/deprecated('`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead', function* forEach(source, visit) {
+function* forEach(source, visit) {
+  console.warn('`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead');
   return yield subscribe(source).forEach(visit);
-});
+}
 
 export { ChainableSubscription, Subscribable, SymbolSubscribable, createSubscription, forEach, subscribe };
 //# sourceMappingURL=subscription.esm.js.map

package.json

 {
   "name": "@effection/subscription",
-  "version": "0.11.0-6fb5df6",
+  "version": "0.11.0-70ecf47",
   "description": "Effection Subscriptions",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

src/index.ts

@@ -14,9 +14,6 @@ export { Subscription } from './subscription';
 
-import { deprecated } from './deprecated';
+export function* forEach<T,TReturn>(source: SubscriptionSource<T,TReturn>, visit: (value: T) => Operation<void>): Operation<TReturn> {
+  console.warn('`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead');
+  return yield subscribe<T, TReturn>(source).forEach(visit);
+}
 
-export const forEach = deprecated(
-  '`forEach(source, ...)` is deprecated, use `subscribe(source).forEach(...)` instead',
-  function* forEach<T,TReturn>(source: SubscriptionSource<T,TReturn>, visit: (value: T) => Operation<void>): Operation<TReturn> {
-    return yield subscribe<T, TReturn>(source).forEach(visit);
-  }
-);

src/subscribable.ts

@@ -6,3 +6,2 @@ import { Operation } from 'effection';
 import { SubscriptionSource } from './subscription-source';
-import { deprecated } from './deprecated';
 
@@ -14,8 +13,6 @@ export interface Subscribable<T,TReturn> {
 export const Subscribable = {
-  from: deprecated(
-    '`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead',
-      <T,TReturn>(source: SubscriptionSource<T,TReturn>) => {
-        return subscribe(source)
-      }
-  )
+  from<T,TReturn>(source: SubscriptionSource<T,TReturn>) {
+    console.warn('`Subscribable.from(source)` is deprecated, use `subscribe(source).map(...)` instead');
+    return subscribe(source)
+  }
 }

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

100642

decreased by-5.94%

Number of package files

32

decreased by-5.88%

Lines of code

936

decreased by-6.59%

No dependency changes