@graphql-yoga/subscription - npm Package Compare versions

Comparing version 2.1.0-canary-80e0902.0 to 2.1.0-canary-a4b1097.0

cjs/createPubSub.js

@@ -67,2 +67,1 @@ "use strict";
 exports.createPubSub = createPubSub;
-//# sourceMappingURL=createPubSub.js.map

cjs/index.js

@@ -14,2 +14,1 @@ "use strict";
 Object.defineProperty(exports, "pipe", { enumerable: true, get: function () { return pipe_js_1.pipe; } });
-//# sourceMappingURL=index.js.map

cjs/operator/filter.js

@@ -22,2 +22,1 @@ "use strict";
 exports.filter = filter;
-//# sourceMappingURL=filter.js.map

cjs/operator/map.js

@@ -21,2 +21,1 @@ "use strict";
 exports.map = map;
-//# sourceMappingURL=map.js.map

cjs/typed-event-target.js

 "use strict";
 // extends EventTarget types and adds typed Events
 Object.defineProperty(exports, "__esModule", { value: true });
-//# sourceMappingURL=typed-event-target.js.map

cjs/utils/pipe.js

@@ -33,2 +33,1 @@ "use strict";
 exports.pipe = pipe;
-//# sourceMappingURL=pipe.js.map

esm/createPubSub.js

@@ -1,2 +0,5 @@
-import { Repeater } from '@repeaterjs/repeater';
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.createPubSub = void 0;
+const repeater_1 = require("@repeaterjs/repeater");
 const resolveGlobalConfig = (api = globalThis) => {
@@ -34,3 +37,3 @@ if (!api.Event || !api.EventTarget) {
  */
-export const createPubSub = (config) => {
+const createPubSub = (config) => {
     var _a;
@@ -52,3 +55,3 @@ const { Event, EventTarget } = resolveGlobalConfig(config === null || config === void 0 ? void 0 : config.event);
             const topic = id === undefined ? routingKey : `${routingKey}:${id}`;
-            return new Repeater(function subscriptionRepeater(next, stop) {
+            return new repeater_1.Repeater(function subscriptionRepeater(next, stop) {
                 stop.then(function subscriptionRepeaterStopHandler() {
@@ -65,2 +68,2 @@ target.removeEventListener(topic, pubsubEventListener);
 };
-//# sourceMappingURL=createPubSub.js.map
+exports.createPubSub = createPubSub;

esm/index.js

@@ -1,6 +0,13 @@
-export { Repeater } from '@repeaterjs/repeater';
-export { createPubSub } from './createPubSub.js';
-export { map } from './operator/map.js';
-export { filter } from './operator/filter.js';
-export { pipe } from './utils/pipe.js';
-//# sourceMappingURL=index.js.map
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.pipe = exports.filter = exports.map = exports.createPubSub = exports.Repeater = void 0;
+var repeater_1 = require("@repeaterjs/repeater");
+Object.defineProperty(exports, "Repeater", { enumerable: true, get: function () { return repeater_1.Repeater; } });
+var createPubSub_js_1 = require("./createPubSub.js");
+Object.defineProperty(exports, "createPubSub", { enumerable: true, get: function () { return createPubSub_js_1.createPubSub; } });
+var map_js_1 = require("./operator/map.js");
+Object.defineProperty(exports, "map", { enumerable: true, get: function () { return map_js_1.map; } });
+var filter_js_1 = require("./operator/filter.js");
+Object.defineProperty(exports, "filter", { enumerable: true, get: function () { return filter_js_1.filter; } });
+var pipe_js_1 = require("./utils/pipe.js");
+Object.defineProperty(exports, "pipe", { enumerable: true, get: function () { return pipe_js_1.pipe; } });

esm/operator/filter.js

@@ -1,4 +0,7 @@
-import { Repeater } from '@repeaterjs/repeater';
-export function filter(filter) {
-    return (source) => new Repeater(async (push, stop) => {
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.filter = void 0;
+const repeater_1 = require("@repeaterjs/repeater");
+function filter(filter) {
+    return (source) => new repeater_1.Repeater(async (push, stop) => {
         const iterable = source[Symbol.asyncIterator]();
@@ -18,2 +21,2 @@ stop.then(() => {
 }
-//# sourceMappingURL=filter.js.map
+exports.filter = filter;

esm/operator/map.js

@@ -1,6 +0,9 @@
-import { Repeater } from '@repeaterjs/repeater';
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.map = void 0;
+const repeater_1 = require("@repeaterjs/repeater");
 /**
  * Utility for mapping an event stream.
  */
-export const map = (mapper) => (source) => new Repeater(async (push, stop) => {
+const map = (mapper) => (source) => new repeater_1.Repeater(async (push, stop) => {
     const iterable = source[Symbol.asyncIterator]();
@@ -17,2 +20,2 @@ stop.then(() => {
 });
-//# sourceMappingURL=map.js.map
+exports.map = map;

esm/typed-event-target.js

@@ -0,3 +1,3 @@
+"use strict";
 // extends EventTarget types and adds typed Events
-export {};
-//# sourceMappingURL=typed-event-target.js.map
+Object.defineProperty(exports, "__esModule", { value: true });

esm/utils/pipe.js

@@ -1,2 +0,5 @@
-export function pipe(a, ab, bc, cd, de, ef, fg, gh, hi) {
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.pipe = void 0;
+function pipe(a, ab, bc, cd, de, ef, fg, gh, hi) {
     switch (arguments.length) {
@@ -29,2 +32,2 @@ case 1:
 }
-//# sourceMappingURL=pipe.js.map
+exports.pipe = pipe;

package.json

 {
   "name": "@graphql-yoga/subscription",
-  "version": "2.1.0-canary-80e0902.0",
+  "version": "2.1.0-canary-a4b1097.0",
   "description": "",
@@ -5,0 +5,0 @@ "dependencies": {

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

21561

decreased by-27.9%

Number of package files

20

decreased by-31.03%

Lines of code

401

decreased by-38.02%

No dependency changes