@graphql-yoga/subscription
Advanced tools
Comparing version 0.1.0-canary-820cb0a.0 to 0.2.0-canary-57e9b9d.0
@@ -0,1 +1,2 @@ | ||
export { Repeater } from '@repeaterjs/repeater'; | ||
export { createPubSub } from './createPubSub'; | ||
@@ -5,1 +6,2 @@ export type { PubSubEventTarget, PubSubEvent } from './createPubSub'; | ||
export { filter } from './operator/filter'; | ||
export { pipe } from './utils/pipe'; |
36
index.js
@@ -84,4 +84,40 @@ 'use strict'; | ||
function pipe(a, ab, bc, cd, de, ef, fg, gh, hi) { | ||
switch (arguments.length) { | ||
case 1: | ||
return a; | ||
case 2: | ||
return ab(a); | ||
case 3: | ||
return bc(ab(a)); | ||
case 4: | ||
return cd(bc(ab(a))); | ||
case 5: | ||
return de(cd(bc(ab(a)))); | ||
case 6: | ||
return ef(de(cd(bc(ab(a))))); | ||
case 7: | ||
return fg(ef(de(cd(bc(ab(a)))))); | ||
case 8: | ||
return gh(fg(ef(de(cd(bc(ab(a))))))); | ||
case 9: | ||
return hi(gh(fg(ef(de(cd(bc(ab(a)))))))); | ||
default: | ||
let ret = arguments[0]; | ||
for (let i = 1; i < arguments.length; i++) { | ||
ret = arguments[i](ret); | ||
} | ||
return ret; | ||
} | ||
} | ||
Object.defineProperty(exports, 'Repeater', { | ||
enumerable: true, | ||
get: function () { | ||
return repeater.Repeater; | ||
} | ||
}); | ||
exports.createPubSub = createPubSub; | ||
exports.filter = filter; | ||
exports.map = map; | ||
exports.pipe = pipe; |
{ | ||
"name": "@graphql-yoga/subscription", | ||
"version": "0.1.0-canary-820cb0a.0", | ||
"version": "0.2.0-canary-57e9b9d.0", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "dependencies": { |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
16241
9
308