@effection/events - npm Package Compare versions

Comparing version 2.0.0-preview.7 to 2.0.0-preview.8

CHANGELOG.md

 # Changelog
 
+## 2.0.0-preview.8
+
+### Patch Changes
+
+- a13987f: make operation resolution an interface. Make operation iterators
+  an operation.
+- Updated dependencies [a13987f]
+  - @effection/core@2.0.0-preview.8
+  - @effection/subscription@2.0.0-preview.9
+
 ## 2.0.0-preview.7
@@ -4,0 +14,0 @@

dist/events.cjs.development.js

@@ -80,4 +80,4 @@ 'use strict';
 function onceEmit(source, eventName) {
-  return function (task) {
-    return function (resolve) {
+  return {
+    perform: function perform(resolve) {
       var listener = function listener() {
@@ -91,7 +91,7 @@ for (var _len = arguments.length, args = new Array(_len), _key = 0; _key < _len; _key++) {
 
-      task.ensure(function () {
-        removeListener(source, eventName, listener);
-      });
       addListener(source, eventName, listener);
-    };
+      return function () {
+        return removeListener(source, eventName, listener);
+      };
+    }
   };
@@ -98,0 +98,0 @@ }

dist/events.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";var n=require("@effection/subscription");function r(n){return"function"==typeof n.addEventListener}function t(n,t,e){r(n)?n.addEventListener(t,e):n.on(t,e)}function e(n,t,e){r(n)?n.removeEventListener(t,e):n.off(t,e)}function o(n,r){return function*(){return(yield u(n,r))[0]}}function u(n,r){return function(o){return function(u){var i=function(){for(var n=arguments.length,r=new Array(n),t=0;t<n;t++)r[t]=arguments[t];u(r)};o.ensure((function(){e(n,r,i)})),t(n,r,i)}}}function i(r,o){return n.createStream((function(n){return function*(){var u=function(){for(var r=arguments.length,t=new Array(r),e=0;e<r;e++)t[e]=arguments[e];return n(t)};try{t(r,o,u),yield}finally{e(r,o,u)}}}))}exports.on=function(n,r){return i(n,r).map((function(n){return n[0]}))},exports.onEmit=i,exports.once=o,exports.onceEmit=u,exports.throwOnErrorEvent=function(n,r){return n.spawn((function*(){throw yield o(r,"error")}))};
+"use strict";var n=require("@effection/subscription");function r(n){return"function"==typeof n.addEventListener}function t(n,t,e){r(n)?n.addEventListener(t,e):n.on(t,e)}function e(n,t,e){r(n)?n.removeEventListener(t,e):n.off(t,e)}function o(n,r){return function*(){return(yield u(n,r))[0]}}function u(n,r){return{perform:function(o){var u=function(){for(var n=arguments.length,r=new Array(n),t=0;t<n;t++)r[t]=arguments[t];o(r)};return t(n,r,u),function(){return e(n,r,u)}}}}function i(r,o){return n.createStream((function(n){return function*(){var u=function(){for(var r=arguments.length,t=new Array(r),e=0;e<r;e++)t[e]=arguments[e];return n(t)};try{t(r,o,u),yield}finally{e(r,o,u)}}}))}exports.on=function(n,r){return i(n,r).map((function(n){return n[0]}))},exports.onEmit=i,exports.once=o,exports.onceEmit=u,exports.throwOnErrorEvent=function(n,r){return n.spawn((function*(){throw yield o(r,"error")}))};
 //# sourceMappingURL=events.cjs.production.min.js.map

dist/events.esm.js

@@ -78,4 +78,4 @@ import { createStream } from '@effection/subscription';
 function onceEmit(source, eventName) {
-  return function (task) {
-    return function (resolve) {
+  return {
+    perform: function perform(resolve) {
       var listener = function listener() {
@@ -89,7 +89,7 @@ for (var _len = arguments.length, args = new Array(_len), _key = 0; _key < _len; _key++) {
 
-      task.ensure(function () {
-        removeListener(source, eventName, listener);
-      });
       addListener(source, eventName, listener);
-    };
+      return function () {
+        return removeListener(source, eventName, listener);
+      };
+    }
   };
@@ -96,0 +96,0 @@ }

package.json

 {
   "name": "@effection/events",
-  "version": "2.0.0-preview.7",
+  "version": "2.0.0-preview.8",
   "description": "Helpers for listening to events with effection",
@@ -24,7 +24,7 @@ "main": "dist/index.js",
   "dependencies": {
-    "@effection/subscription": "2.0.0-preview.8",
-    "@effection/core": "2.0.0-preview.7"
+    "@effection/subscription": "2.0.0-preview.9",
+    "@effection/core": "2.0.0-preview.8"
   },
   "devDependencies": {
-    "@effection/mocha": "2.0.0-preview.6",
+    "@effection/mocha": "2.0.0-preview.8",
     "@frontside/tsconfig": "0.0.1",
@@ -31,0 +31,0 @@ "@types/node": "^12.7.11",

src/once.ts

@@ -58,9 +58,9 @@ import { Operation } from '@effection/core';
 export function onceEmit<TArgs extends unknown[] = unknown[]>(source: EventSource, eventName: string): Operation<TArgs> {
-  return (task) => (resolve) => {
-    let listener = (...args: unknown[]) => { resolve(args as TArgs) };
-    task.ensure(() => {
-      removeListener(source, eventName, listener);
-    });
-    addListener(source, eventName, listener);
+  return {
+    perform(resolve) {
+      let listener = (...args: unknown[]) => { resolve(args as TArgs) };
+      addListener(source, eventName, listener);
+      return () => removeListener(source, eventName, listener)
+    }
   }
 }

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

52127

increased by0.21%

Dependency changes

• + Added@effection/core@2.0.0-preview.8(transitive)

• + Added@effection/subscription@2.0.0-preview.9(transitive)

• - Removed@effection/core@2.0.0-preview.7(transitive)

• - Removed@effection/subscription@2.0.0-preview.8(transitive)

• Updated@effection/core@2.0.0-preview.8

• Updated@effection/subscription@2.0.0-preview.9