{"_id":"@mgfx/task-bull","_rev":"36-5d730d216a68eae4a28c1d27a09624bc","name":"@mgfx/task-bull","dist-tags":{"next":"0.1.14","latest":"0.1.18","beta":"0.1.37"},"versions":{"0.1.1":{"name":"@mgfx/task-bull","version":"0.1.1","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.1.1","bull":"^3.13.0","mgfx":"^0.2.0"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"08479293eac7ee39ccb8eb34f3737d1ee941ee59","_id":"@mgfx/task-bull@0.1.1","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-qIR4K0s5wW+eUqofwRZqjPpbLFyVQLtc9bLF1BReQ1HJ5vFgo7XEdRmOnhThINKaDtPvYM71No20VIcIpUnXNQ==","shasum":"0d8a33e7caa57e648e44b0b24b3f2b0b2d3b5667","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.1.tgz","fileCount":7,"unpackedSize":9660,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeYO9tCRA9TVsSAnZWagAAzHMP/A7Gj0atObLa/TTyFnPn\nVB6kXfYLiT0yuKJEiwqdYi/5BsOTnzbqhJ+TpZxEP8s4aNMZL4+topps0HOC\nGd7e5gFd8PwvauZDam6CClFBJFJPxw+z8KRDKvOxJJqjYs+MqoZ6/VlAcuMu\n3Swj+9n0d9es4++7TwIO+GAO4CDbK3zlMth4RojnhOrChD629zKBoKBvFVmt\nfiYF034KpD8I0Mn+zTSwy1ssZJaUwjOF7XtTcknyw82ooXmr8DGKyLlC2Ak4\nbBhQnMBGSDCBs/qjJvKXM/14XalrplLKNU2vawdJbxWpIfRI8Ye1oxVCNpsA\nSguij6rrdfT3g9e0FxLfjrAryqEtopg2g1Z0ILOkp6BCRG8//rVh5U7Nfcwf\nUvQA5YRy+LUHjh73E0gy47hmw4qDIrWq7S8bOvskJlTghRYS0d0xM9YcXWu7\ntAaiSi3UIQqE/ALpyYoXGVe91DdBve+vai3KeJBL09k+Oqc8LLmHUg/aUNwb\nRUOSHkXLIeQvgpNBeme1cEvS3Vxe4aTBKQA7urkeMmSC5xkKmbPynFe7N9zA\nL4PeQfL4WkP2moar5KDcsjCKX2MQyxKhvfzlViznToK4Pvx3+7w/jtaFck3m\ns+7Bk+a5Nue9Uq1C7Tw7N9O4lUtWLzS4W7hhrmiUR7ri9vbXZ/c9gdb56bfI\nRi7Z\r\n=7xzb\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCSGMjOhwOt9E4NoydgqW1MtVh4VEn/ZxSTitKam1XxZQIhAOMBmXmYpZTNgFf2b5QpUh7WOOI4FMelmzP22Cz15iCt"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.1_1583411053156_0.6269020534804113"},"_hasShrinkwrap":false},"0.1.2":{"name":"@mgfx/task-bull","version":"0.1.2","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.1.2","bull":"^3.13.0","mgfx":"^0.2.0"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"e62814eb6602dcc3de619ad1f104244bbf904bb5","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.2","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-1j1s9pR8UIVBBRUAiruTgexZskVlQDhChEpU+qtBpQ+ysuyaB+Lc7mnE52w/0olpbkhBRBfEPyhjcWWnSAsu4A==","shasum":"fcdb5d2a955e7a4d04ba45d4d5dc47de2a17bbfc","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.2.tgz","fileCount":7,"unpackedSize":9838,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeZhZ/CRA9TVsSAnZWagAAn6AQAIKusOFuwRvuBfHW9DE/\n6v+0qEYvRfhZe36veGEBEKiNdJYWy1HRoDctritq52lNsqhtUTuRV9/Cn1Xk\noKtj4YIhry0JVwsNG3FTsFLYdFyeMLWa7ygrgRzZ++zoPx25Q6bWiT/0zFQl\nEfs0LOzmDAuIQFbtaW/4AE0Fj7SxaqBAgywVL9Oa3DKHhGnV/yeiyhTYKp5L\nEMfGbkYrlUkxX2PYW01k8vmlpnes82wID2jgBJ3pvMNvrDmVR/8CHFoJJEcZ\nAhdwCYSivPPmo0nxtmibzhArZlWF36gWMmleBH56YcPFUcy/ZfCJ8KuOdX9a\nbuIYVmidbtkxHnGJInjpJAVkBg0gOpisHY+4PP/Y5nLdO3BdjC5cjvG4ymcj\nQffNncFP0jlHJkeEDou5sluThfQFz/2CBXgiXsaerbnIfvw684Necwjfd5mf\n4byRFiZ7zjm5zKaBhDh0Qwtu3Lxg29ajSk4AIMf08ZeiSdijt0EdnjyC4qQ/\npeAoNSo8Kyy7KX3p3uMRTPBFvxPDzxbi5eXVFv3/f5oGYabNV9XaE6MYjxdF\nzalSasY1/nXVMq/jStiE9weIORuuoExgDvZnuMNxivOd37mTtO2XuZU0ZmhM\nP+AaiwgDGxBouw5Gm8ZSWrIveaRhXoFri64A3+9o76uAvtKc14P0p5mTt2vt\nk+v7\r\n=h+ad\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCUHtIbnlOHse2KDpJ7mhSe95MJiqg6lnmhETvnHsmc4gIhAPeW+jNxZkFOpnLjBsGXT0UdUK/Fcd2BVKwL4nQzGhIO"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.2_1583748734820_0.8420245572250011"},"_hasShrinkwrap":false},"0.1.4":{"name":"@mgfx/task-bull","version":"0.1.4","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.1.4","bull":"^3.13.0","mgfx":"^0.2.2"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"c14507bc91efbe20c6c937b193452785f2662669","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.4","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-chG2q6f+83UDpxXgM3JprQLLfoVLb2w1ex9oP4W6bDo3WHsfBBFL9DwPzz0vZVGl77uAwWj7+kiXYsqlmmTKew==","shasum":"0de932d333bc8c05a33bd0439dc02d70bebefda8","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.4.tgz","fileCount":7,"unpackedSize":10194,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeb5foCRA9TVsSAnZWagAABQ4P/0KDjRDlPS2ob/tIhdBh\nVj7LlWGbmBG5aCMePZujOB1ovD8XDuGRCNUbn8RPWiOMb9dwumBjOMPN7ddC\nNY+K53kWkdkJgShdE1xtkybu9HPWjOYq9L7o6TvvVIM4wYUj8/mpe2WrQMCY\nyc1iHAiaopY9WSaIJryC3EOOy+00jmy8+1tWjVeqbHWBN/KQbhFU2F7MK3X8\nTA9W8VESz8sSDAxcNxH9aixzxK8yPop6D28dVnSJ1wV1XuuC5I8GLp/9vn58\nHzsCjT6Bxva8SOdzjjKMnbiPNV1OaX0HYFFQ/yZpUoPAdOpLEhiTflC5wHIL\n6Y9kepdNyIhkietp5S/ET3/LKEWm0LxQD/BlZkcrm5TwMz8Bg/tOdCQ2Grai\nCW+WKBq3dBF9u4j3cyHz0MRoBMHd8alWzfR4FvcVlNUkE+eT2vagqwo30Kli\ngfbXsJ5hCpDfuWwey7sm8Ku0gXLdihqG3ovnX1HqMUwO7IdcwyuRl1Whkljr\naLjevnLLIfA2H4dMBkWl097ENCKnpPw8ufa2iqplXT3bLbp6QuG4/9sgVyHs\n+ad6ckT2dwqaB8cyRWhW5jB3D4II4UR+WSYrd8qxUlXuxPdxWPchKaJKRROv\n1qtDrJPFusvBMfwsh6w/x7BqNaB+aJtSqumD5+em4L5O8Ml20i8Yx5jMNPxp\nRPwo\r\n=CqTh\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDH5ZN/R80XcdqSrqxtawPOJ01k/qci8U8Vq7tbKF9btwIhAIaDTiFwS9jVYNhRPrV+oO0O8LgQk6I8EhSDmWVWZVKi"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.4_1584371688652_0.22757625555554095"},"_hasShrinkwrap":false},"0.1.5":{"name":"@mgfx/task-bull","version":"0.1.5","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.1.5","bull":"^3.13.0","mgfx":"^0.3.0"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"6227aa9c8ea4e676901d1760b4fd304228b50a44","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.5","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-80bb6DL1UJPjJR/iYIZPoONcrSbpy/BghZeVmNZC8HnkomRroAf+NVZQwvnZdsHghXaxoRYXBwUh7GQGdlOD+A==","shasum":"86a797b8dba429ef6e81dc4a6d6870d1c251eb06","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.5.tgz","fileCount":7,"unpackedSize":10372,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeb8dWCRA9TVsSAnZWagAAYS8P/j/slPXvO8sWXzZQ5ISO\n7vhaHkHyw+rd0yV2/0pA5Q8Ov4230BIhAjbuFTtPLBlAhqbNFyFPhC4zmOSH\nAjAHpM/rt+TsBo56AAgm5vVMnwQ1IdaLeaompm1vY5UsW+ITl7dKds+99OUb\nW5ivE4iy0OlKN2xpIDIlCCIpTtRw2q//kiE8QbP1IMZxr20/W7sHrmix4Ac9\nygItgSRyaKNQsEYJvapNaD37xglMR28jriblZNHhGWCEVGZ+cbMcjdfECofb\nS0J1ntRJEU+8RsYsYm+jlNPy3hjoEWSY3fYfWdXe/WTeHoJ6EJLrbuXYf4QL\nCm40b+3fe2FIWWMmnGv7XFmASrZ0WqFd3KJngADbOMNzxRkg3umUfuoa5/LZ\nA1l09ee2j0D+5YYr6BItk6htyWRnZs9ESHor7SbA1D9EN3DaenqGP7WWqaAR\npKda6NPVBq339uM4nm4vTxNYWdq+UMemdTpxp4l/mqn2gYfzGzFjd7HmP7nw\nxVAI6NKjWriexkB4AdRgaXQMP+LZQWPB9rwavqPpXvFXSG0L7qoZS+/eoCg6\nS2oHCnu0R4QmbKt7pkuU1TMBLPiogi0lGsu733PbvPxuyTxV5NvSo+uf817m\nKzYHtblS9zxVwagROc6x4p73ylZBENpIPCVcKq+MOUvSapopQsNVbcL0HKve\nneWA\r\n=oX7B\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIEcC9eSA3ixG1CJ/1s2zYV+MexGwIn4O4jwAD9kXBcpvAiEAhHGuS1y6bJ6pjTpJiBnM5mNFN1jPETG8suE51k4mn9M="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.5_1584383829651_0.7695907882776349"},"_hasShrinkwrap":false},"0.1.6":{"name":"@mgfx/task-bull","version":"0.1.6","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.0","bull":"^3.13.0","mgfx":"^0.4.0"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"72a1d24dc0e65e2df4ece919f4ad0f4898452597","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.6","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-BYrzbJfJK/NwWbo5B+KfoTf5NOFkP5AKE7JxR3eKBsj5iH49kflufY+kbE3mVmlKaNOGy+2DAR6XFp2329AAdg==","shasum":"f2e5f83c83182a27fc2a513120b0ac36914f7523","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.6.tgz","fileCount":7,"unpackedSize":10550,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJegyIsCRA9TVsSAnZWagAAobMP/RpYj5qlc/py5v/AA5tn\n1vnUWoh392nsDWKjq2FgJEPw2rvxDCRv4J4mbZf86Vc8kRBSbYcC4DFyfVEG\nWbEY1YfgcpLtjQAo6n6ikC+3qj5wNobgGNUzaXyKwWShrTj4ImrKc5c9ClB1\niwlLXeSKEMFmM1ooKDqCV9HG7HVo88hYijMFTJIXYRx3U2SmsKlyrHtSPh1O\nusTtpYTQeFjhyAT1PPe5QxXF1FbTdbw31oG313/rcyrCUDrG5WgGWHmm05i9\nEf8eL0r7534BaLX9hMWzS7hkY5q6rJnOeL8OAztEO92goGQ3hxzUtStn6l2g\nVi2y2b3IFNhgbmVaO3HQC+v7r77AfFZE3BkxoJ7mxO8umqP5Uu/rfjan1zIm\nD2rhsjiR3r3Xsxare3YV8RVL6EbykjvLRMJY9KanaRQLzVLjQ0rkKoAxyOHa\nTiLBiV2mXN6vxn80AtSVsH4hA2XuZMM5Zzy+P1aWGGH3uKyHuY07lT0/OraZ\n9nOCHfgYGOUAwb+8s/rNFhX0OxVejhLPOr+KWMib4IzkAvVNsW+n6nLZaagz\nKQHExbj9IiKfHM5MuKWaL31VtNipqXwnsX6Za+eX8g7FdnxtLU6VaUghAYPj\nIBXt4rWS+bEhfEj2GdvKXWgjRZ3o/W5fF7RpMzbnwUzoNHMGcxxGOSXYMxkD\nN6zw\r\n=q8mG\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBEIe/hDjyAqnYm//KFEmOwnNrEZnqTRkcFaGTmmaCmJAiEAo1CB64ZL5rFnnSisE/C6rrGoL1kMBQ0ZE1+xXsDcB0c="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.6_1585652267648_0.4313662627280086"},"_hasShrinkwrap":false},"0.1.7":{"name":"@mgfx/task-bull","version":"0.1.7","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.1","bull":"^3.13.0","mgfx":"^0.4.1"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"58e232ef3d2b7e0246e6424427cb6bd0bc3c60fa","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.7","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-O2jVf60rPVWNggd7/DM2vn/a45OorqwwZ5Mt9s29AA/JvCmMYOiFgqi90vk2e6vetiKKQqpfrLcogHyzsWc/rQ==","shasum":"3dddfe4fc7bdf95d0c76a2b36ca4e40c2b3477b3","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.7.tgz","fileCount":7,"unpackedSize":10728,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJegyeDCRA9TVsSAnZWagAAhIkP/ifT5e1TU532fXZY5mdC\nAMf+oJiFW7U17l5i3UhvfTJh1ZnMx/mcAHSPDn6lOPA1J5R7HnZZaxiJetSR\nnnj17Zirgj4Qi0LCTBMnlynlLYNzG8udytSO7kxhq7i4t/wOAphmcQECm32I\nmcQfJCKK9n/T8EQtuIzsov1rmFKIoL7K1xZmQsNIosuUKdY4zXaNEaU99Zfe\nhDt6VHrO6+kdnLI5mNSEWiaovKvA3GRpc+V7W0isr29zyYBUdu6fLI1Afjvj\nZGQu6zuvS4FHKDXQ57jLeuk9bHHNpguRG2yA3y7cHVRbMZ4AQv0cUnBesmI7\nyaXnG2KX391ok2XvmC4moW4XdfmQ3ff/qmIJcjH/LumtMYEnJ77pp2BaKaq/\nQQHXeJzBya3WtG51kjNcXBOaBCRBI05uZwCHhXkmlpnJFGp9R0aen6HxVf8x\n29dnZe+JoecLjTBJu2RumIddpc06+cIn9qjC3XwzPxXvTSQ97c5IMjUuC5af\npws60DGbI9hLWO68alwp7a0y7eqi7QtseupbfejFzt1P47Gktzo/hOldyaiU\nFLEDC9rCSVOYY9PBvQa8e9CTDnbDhu5QeRwgyiB/7Gnq1DQmgTqW3TyQ1cK7\njv7BuJgWCumqOYltsdiLSq5W+2UlRx8h5V2x9nFwkwY6eC3G//C2Z2m9hd4s\nlI3N\r\n=XyJj\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDOYhe8SlHkz/TpBvKi76gEy4trIq99CIjZV59jwv9aJgIhAN3eFb8umMbfG31Vsk6g+6MWY+ClKBZZ0/uKcrDNsAqS"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.7_1585653635184_0.737045104984485"},"_hasShrinkwrap":false},"0.1.8":{"name":"@mgfx/task-bull","version":"0.1.8","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.2","bull":"^3.13.0","mgfx":"^0.5.0"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"d2e981ff3b00192b3ee0ada78a848b1daf21973b","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.8","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-kRaai9BhaKaBDPzrVziBZdb/CdpS9fKHP99+5eZg7X9OkpKxeQHYWcKHmkCmrk3SI2uAeIHI+v0qdEL6KK2fSw==","shasum":"02d95592deb37f617f8109f1b1a56a99743b2a70","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.8.tgz","fileCount":7,"unpackedSize":10906,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehQY/CRA9TVsSAnZWagAAuQAP/2zw1rDFyg//50P4edxd\nKsZl0151MQWTTU3ww7kLSDwytFx/C3Ue3ToG9NdA8xuI97jOWrbBAjTADHr1\nIWrlQ1m5vYreZqx9vAPWLCgj/POHjX6oVBb6GYuTUwuV29DOWqU+bltpvctE\n3USoOaBeyRzbBVVMQCL4VkjkNe5JJQZddlVrAPh42LF240AZGT0SM4ziXNUM\nTNJadPSXJCPk19OKw/mQ4MhQxCmu10QmJ+ZPKDt9WrbQInGcmj/v7Hevn/m0\n3CZlOIEvf346linBEt2AOH891hcUx21PYkxLYNhALD86Zi6HqhhbAtifyA1l\n6if9YWa83nlhqXEbCWHDKcY4UwXm6HQJxYKCEw+JykLzdGC+NGk2UPXrlPMC\n0MKTpKRBPAB7ZGI7HQ1B2KqMkGdCm8ChotjL/X17vcSdgWnx3/XdbI7/R8dx\nlLzivTOAHami9swWcqAmS8xpAvCzm7HhmMvWK7sidvsNDDdDE/CtVHA7rECY\nNeflLIEVqeVGkAcV9Xyil622upGvYgy9tsYCKH4Nam4xVph5F5H0q2jW0MLf\nU7Eq5UuuTxZVcpR5qR1N0xXIS8kyoKMxTVGZ5fqATut3Yczm8QzTwKmI+I8e\nfbzwHQ2rDXyw8dsYksXUYWnkPzw0cD7Ktna/y8D/Ou20pw7cPasFvpr4MSz3\nSQrE\r\n=xTkf\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCedtt3BHeOZE2p01YX9KtVIk+leJJssef5NEzfYheJPgIhAOWwahI43xyDMCb8bCnuDFrCDQSX8XzJ2XICGZKTg7vn"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.8_1585776191432_0.8086442397483471"},"_hasShrinkwrap":false},"0.1.9":{"name":"@mgfx/task-bull","version":"0.1.9","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.3","bull":"^3.13.0","mgfx":"^0.5.1"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"b8c5dca9ed8ee5b9fe0e1e62267d42f7dcb921b3","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.9","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-2BVuE4S1UZb/xHyDdlyOsH/CeH/EhERVHfsLEjqEr7Yk5D4Pt6mBNPEOzKMPD1Fmk5pw2TFAt4SwQmrxV3MvSg==","shasum":"ae432df3265ad1a60bf7e8ca100b182a2e06da7c","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.9.tgz","fileCount":7,"unpackedSize":11084,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehYTRCRA9TVsSAnZWagAAzLUP/3bJC4Wkm7ej0c/LWENF\nrTsVXvvsfepx+z2EEZDtl8nuaK3ZVI/F2/NosXo9eZWK5LHMg1pBC3oSjH0H\n5RpobvbwcovLNs36XQZAbEWqIzXIHTYGFybhh26Iv9r597sy5oNCRdZSnL2N\nXOzaq0FIt0LU2wYhlvVLDii+4Q0YD8JuhodpMTUQUE3z3Z00lXdWTRe2tCxO\nGXIpVA1KsqJ/FSm3TPoJpBbc7U4/qx+esiYKbAKwBTBZ1gkQb3EjqKkdVBBX\nYuuzYKk/N78Ax1C3bhvrS8MgwUNdqDhmaaOvKE9jfCfP8AWkYUelXnnq0qWM\nVx9TtxvTrknXx0lplWUju0IhfdWGm16yVFqIF3SCKRYt6LDpNVtGQZvVqYkr\nYm7arlqHzqnF/08ViurNNAW+pQynuFUflYgbU04U91q3+BlyXruBiPGKn3fk\nv0Lv0n7jBhRX9eG5QOOz+QFvhSGLQrnlSNlfdfAs+hGV6a5L1c7UbyVLhINU\nCzXAlqJl0WZLJn4rc3QgYo6jfpDEsG/AKQATMsu1HnYVvn6ctPjlm47mVwJA\neJa3+YeKIqjTLnWC+ZUH5363B5NblEKflIYaezumJn+bSEjwGqCU8IH3mXYp\nLYpV8DUtBslGWqovnRzaVyX7qOVpR+qvp1A/kQRgYxc5BQspU8JUGybmedp/\nsU97\r\n=Lchw\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDYAe192pHjvW8In3GcKhQnPvTB1jjd+gKy0rXx4CdIzAIgcQ/D33DodeO6R57k3ywKfukMAxPQbtAUv3jY4/uRlJU="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.9_1585808593401_0.32247298768473365"},"_hasShrinkwrap":false},"0.1.10":{"name":"@mgfx/task-bull","version":"0.1.10","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.4","bull":"^3.13.0","mgfx":"^0.5.2"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"2d94c42affe84d4bf217e5989314bf38c0c8e94d","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.10","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-yoZUiTvxTadJyVnFG3AzoL1LkJEaKo4djqJf67W0KcwzyVtRxwlS8eXMMLNxNGd/Y8jVWPI3uvqLBxMeE1dHfw==","shasum":"852d062f3ac3a8d860c6f041e0445d158171ef8f","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.10.tgz","fileCount":7,"unpackedSize":11265,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehYugCRA9TVsSAnZWagAAVFkP/31kIJu6t+6N57n8ZhlV\nbmavwyH+qcMDRokPvdsAL7cAVlQvtsLX0F600DrYLhXBeY6WOEzF2c6zRp+D\nGFWoRQaKvFz80YTMfAV/sbYZJMp2tbrIwHYxpI6CPZ3pUGI289pum6vgekjy\nRS1tiKQSPUN0qa+sTZba3HzzXKkngra+GNUuac4j3k/KuQgx9lNvqAEfHxtN\nTPKzVZNOXwbGrTRU/nWcG0e/o7Gc/F5aWpstIKosMmhs9wYxQxqumVsdkeQN\nDeWrXwMlr1fhaUMSUIZNJnIcUrd+/JwWCPByXYqjN1gP69T3xo0FCXmQZ/Tg\nUMTS+0pYHsfe8dbSqvlsG2g18036E7h30tUhCXDipHwOQ9JMu1I/WHOO+mUI\nDMJVDCCy1Xmhuz4R6wI/kM1aepzYk1gjqPXD6t9xLsHztFtRbayxXCcYkdka\n3HTDqQoLyFIOzYko46Mc8M7ss2VWXrotQuDXcpKyLh7LEO9JKS8UnAkf/hmb\nMs1on2T6rISIN5iiJvINHlR1Bx2K9Z25uv4mg37qLskJ4U7MuLRp9lVcWxxZ\nk9r5m8YMkx59ndj1SRVamfTMgmEY5Co5p7tJotNxQ+W0fu+h01oNS7ODeQ6O\nrHaUU2t/g0HbLXbDkrEfUPa2CUTLoFmjRSCanuXUtjpuhKAtw1CMiJ7Sw0KF\nP6M0\r\n=29M4\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHJUd1a1mHI1aV4Vi0tRrhwkW++0ybWFaux1z7uExnX/AiEA/qYUkRy1YicIbE8jV+7nfNnNVccWTR7lso5bkoRkXJk="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.10_1585810335221_0.5011011599791999"},"_hasShrinkwrap":false},"0.1.11":{"name":"@mgfx/task-bull","version":"0.1.11","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.5","bull":"^3.13.0","mgfx":"^0.5.3"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"24dcc2ca860ee0a3f7996d793318aac797968b5e","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.11","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-9D8jhZZzP0aiqE8nq4rqrm8Ki0mQRPkhwrLmLP21Mhpn2x9PWshwbeKLLUrNkMLjHxBEaeAAq+/soJl8XbI0Vw==","shasum":"0f9584afa6d9fb2f1333207b18bc1baa75d7729f","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.11.tgz","fileCount":7,"unpackedSize":11446,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehZkDCRA9TVsSAnZWagAAasoP/Rejthuxx2GLrJrmeH1L\nlFS/+fY5Kga5z5CBulBlv2iUVOnTvY4sMvoqAa0jmL4/Yg+ZdAOXrCbkAFQ/\nGJSwKlBXRXHvMAt/5dvnbxxhwcOFK1Oy8eCj1BF7iCc3hVvJtQQpUtxanhoe\nwNOsAZ0fNzOTr25SC29+fcSUMuJiAupkeYX1Zve/wC51pb8v2kIr/ivb9CGO\nmlwibaNAzBHg5vdJ2pr7d7XXv/EFyS0T+bAJiJLxGworadUcVj7Y/TxAWx6e\n86bCcHe+UdCb4bhI4yn1hYqRW77SvVv4sUuceEaPw+qnKFGLCd1cM+U3on85\ngrgenAp4uRqJxYyzSpL1i7d2ySp2s+mX1szz54RBt6tD1juyR84XUQ8IzCdl\nZTHZ+dWvODt5bd+jiA2HPB2ZwEg7RfBW3ycCcnko5171Qwa8+l4Z1R5dKYX7\nsqYk+2LjuL7E6mKv3HbND6w8AoZraRMFS+YNcp02FXPN9faBVK8puT7bkZWm\n39+4B/3/NOQfPGFtw5rHE3p6RV2j1pcHsSOgTm46yI/3qcV/SKV/tpOeZk7w\nRtwsqCmwRSyKdTmRLq+8W1qmNQDCz5vH73MAfcLVGG/U6dMfH5Jnm0zPbWiI\nCr7PVyrgq2SS/+mBJHPH1omwYXH7g9fsvZDsX9b42We/ONd9kPo5IQLPvggo\nKfIB\r\n=CuDO\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQC/+8UJZPJMCFCio2/u13KFV2QltF6A6+Mhc7kNYoZZxAIgPxJCAXWzLMAIdXLV5bt0Lk3Eq5WE/d/7Q1P7fxFvnMg="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.11_1585813762881_0.7054123812932553"},"_hasShrinkwrap":false},"0.1.12":{"name":"@mgfx/task-bull","version":"0.1.12","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.6","bull":"^3.13.0","mgfx":"^0.6.0"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"15ba4b6d699e5e9d7c88bf07ed4ae3ecf5eb373e","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.12","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-yBCQgrz7XZ/iMlB7ZcJeWUb0HGO+XnbUBmVTDkHZXKRSGMK1lNa+grag4ZstmxPD3kmNrXTD2QwEHlRd7bmyjQ==","shasum":"d11cc3758b44a753dff939bba3f69687a585e096","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.12.tgz","fileCount":7,"unpackedSize":11627,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJehzpPCRA9TVsSAnZWagAAhgkP/ReTOGGYUgUY9vx3eZFv\n+xfpCYKxavEj2O18LGil5t5fuFQVmDnU+4E6Dzwgv1rm+qa0X2hlfYVSnKs4\nIXtX7pMt6lCrwpI1Vw6Iqeq32mO5Fzpgfpy5MSqZ9poh1Lk0oGkMFKnTMDi0\nhvtESIwFmLuyui1LnMHvhCR+qOOAWqE/MtltQwSIL8c86gad0v4hotVjHEQq\nDgPJX039fI2R3DlzAWyxPKcyV1meVSguZrNd7r9QfKAakbyMhdJBrqIPoNsZ\nNZlXwtsQxwvcPNjAh5khpxeMteYz2vDCvmIp9kuila7EuK0o8HLBP8kZCmQJ\n2etuIkS21FNUSZqPlCnqaAyeh0razcgrvqvXY7oKKhFVqzvIkg1ruAlHUnFb\n9E7uN13/Rhk18mWxomw7QI8ZsSqyfCB+ejUmmMgKDUajVixGYa35/KGUeBLZ\n3F1NeO+UlQMp8mRp/sx9dMsvEWXymqhzrlJSz/FGxiEzdGRL4HPnjgehpqxF\nL+5ePRT4pNkdmqPPbG/ErQpT5X5ZAnd4ElH9DCqoNqxZRXUR12e3YdXIW7K7\nc0qeiZmWIcEpPOIxF/pnAukC2uSxxa0VwoFxx/011fFu+nYAeKfvOT2sWbS3\nh33hAhHWrueRnX9y4e/5YSyDr4yt2zxKSKYVbrRLF9/fN8W/7cQt7ZgMI/6v\nTZee\r\n=DEVM\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFEE4mWG3YmC+UnTpVywN161Nvw+nKhbOYRF82YNyaYNAiAoWoQn8Is1i9IaPavR01JsPbm3WFXJZCJ68dlFJcAcdQ=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.12_1585920590936_0.40111559022259446"},"_hasShrinkwrap":false},"0.1.13":{"name":"@mgfx/task-bull","version":"0.1.13","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.7","bull":"^3.13.0","mgfx":"^0.6.1"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"635d0d0d60c6b4cc2fffa46fd6161921ca4ade35","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.13","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-OynBYrPerns3wG/YQOoDAJhNkDj+wOmOGeiwoP1jP8BURObf2sPUh46LMvGZKpzB4nSpX+jsJg3jJSHgcQt+3g==","shasum":"27ae0ccb812f542e19f1b81398fead4c3b9d1c91","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.13.tgz","fileCount":7,"unpackedSize":11808,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejaG/CRA9TVsSAnZWagAAkGEP/3/JxZ3JcgVtiOc4Appj\nq79xydxi/f36xY2bQ2lBuUAeF9ruCfdTYblpUJMex5K4qdOgRSs8vUssilYm\nGK2u1iPAf3j5YwpB4tbTsR1WYQlf7cMCNxthZ23wsuR7qKFT0ICLp4E6OFUQ\n8izg0jyLUGjqOR0SgG7uDxVPdyszoVam5nM8qOBDjS6HRPuwWz53Rlf3BJcd\nAE0qiVA/6vSqy07rxjh5qSZ/M5cfgfvDCtcBRewH0Xn0qOSSS2QrRTvFlZix\n6d597W28JTwuJQ9b6LzcQ5UWFxKdIHVPvVJPn9h1uOZ0yCygV2QtsXv2FeOH\ny5pCMaLnhC1kVodnpaBYGDSQarYNOjsQrGCm3gDypqkvl+04wtJMDblFo48s\nONaRmH+cn4opN3+lB/nYIKjyY/WH/i30pDVByUZZfb4/X4gQUmRTGzhKyLU/\nXPmUYhy4yIRyFw5KAaPuOAnXlQ2Pne8t4Gr3Pq2euIDfOwBjuRcD9iXpLGsN\nqbBV3SO2qC3gVVRIJtI+VnyXIxxY7qjQLJCyNjqwvLRuHpOW1y1Vi4yRoXMI\n+4sSDU504G3hx+atb8+2XS5b6HOigszUwxvanfG+fPkTjnCHDUe8preBn1nd\nZdBYaQI47Qfp/UuugK3sxyZm1PVdCCZQmbyRjZEDJ2oc5yK2cwzfFC42pSZT\nkAF5\r\n=+HC/\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDBtXOQpJdytWRKpDtmhMdxcl/XGVK8FchEFg9YA+vc9QIgEV3GC2Au6CBlB8r1dRuFyOSAGx/1/wEDHADVs0gX0Fs="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.13_1586340286657_0.04108540806484062"},"_hasShrinkwrap":false},"0.1.14":{"name":"@mgfx/task-bull","version":"0.1.14","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.8","bull":"^3.13.0","mgfx":"^0.6.2"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"11172205ebb9da77017ad9a49749579efff4782e","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.14","_nodeVersion":"12.15.0","_npmVersion":"lerna/3.16.4/node@v12.15.0+x64 (linux)","dist":{"integrity":"sha512-LdJo66RkNCoCjHurUzUGoQ/2I/kvCp5OTJKTjcd9miLBioGaORd90pucWrTGoHcnK3+8DxREVh0mllYtg3vLRQ==","shasum":"ce85b7284b6270669e7a9c7b3a53431ea0f27a73","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.14.tgz","fileCount":7,"unpackedSize":11989,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJejh+KCRA9TVsSAnZWagAAEO4P/iaRctoAnh88xHowjrJR\n4uG+rL54o5psYOMbEs7uxOzNbsLhUz/joccETa3MBWk4dNV4RbrwMydsWBMM\nPek8n/uM015oBZDgH5GIllrTFmrJEpt8zJoME3h0i8lDwJxmlqKTOJst5OP1\nl3sN8aROk1uo+GaWwu+77wNAWbjkKATDuPa47fXPZSUwPuB6Rh35X2KjK2cV\n54WVDPW1cEpa530ukm38+sGjaN0SbR6VJLWQTMayvUs4PIYxndvn5dU+uIPa\nemRjmQlBozdvuh8lR1gVMhHEPzMxFolrxTqSdS62mkT9bIvU5SbjIn/CksvD\nCwshEPsQyDkKPt87kTyXgJzG8liu32aZeABnDc+W1202h99JjH2SNQjflrHp\n4ZLF8I4WrBOCAE9vL+13R1Oy511A4q04pvJ43FlxpuePnWFNL3H/NCdfFNn+\nyc/NATgIGcO+9SdLjsgQQzCRJtiKQNrmHOMP0sPAZdFjw1y2/yB0MdkwYYl9\nPWbggWFGTm5XQzFg2yKk3jRw+LIPzLhc/Xy4ZP2ri1jiEDL/FAIocvSKpQz0\nxTtspfZKaFZsD3jWhgPx5VZcGgnrCCDpnimrTFsrgC/JHqtxUdV4uVNh0Xg5\nDTQYwnMFJ32DlC02Ey9rgvzcGneZiUQW7RjCsEldcpJiJ01wf8Hh8TnEEota\nNTqN\r\n=oKJ1\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDzeA0nzKQsNC2bSu2tMOaubuKJQu2GA2FUMQuRTIP7wgIgGm+cJNPigEackCpaM+jLzT5W8TaA1dTlB5gA8yy1AUk="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.14_1586372490148_0.3432630154793901"},"_hasShrinkwrap":false},"0.1.15":{"name":"@mgfx/task-bull","version":"0.1.15","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.9","bull":"^3.13.0","mgfx":"^0.6.3"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"f6520add9e4d9ec7abad887cdbaedcfc4a3b2030","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.15","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-McZyvFyC1V6mH2rehcoA0K3jHFB+f+uVxv+2kTyEpXGjs5CrHJr+FCcrZWIktZN6JvymEjuZihiLlZx8/nze9Q==","shasum":"5555f4295539877b6d09e731fb7f62a175a80051","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.15.tgz","fileCount":7,"unpackedSize":12074,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJerEOpCRA9TVsSAnZWagAAccoP+gJmyIiPjapu5BodJw2D\nd0FGobM/LsM7vZg0cMAaSaAJdU8Z0FByfpr1lnzagRq1iF/YflafynaBNYmY\nUk1pePvSdx8GVOXDQ+Ulrl1163ifS6B5dwFWF9PbQmVmb6oKzM5m7/RLo/rV\nl3M2fMtLh22OLpbpgEaDTG6tCJNZ31l2SKlGRh/Nto61mHfeTx+Pba0Vqqo+\ncUd7cDHruqkO+3rd80S65DVNNFgI91/9txs0IBpjJenVp4GsxktOmzQUAFuh\nEi+SHGEUrfD/MNK6O++Q4+ecqsnbsF+5XwtlUs6GH8sa8fVwTUHfwslA+WnK\n2A1sAwZBJvvVM/T7dOUouk8SEA0aeweNThoYKdGNL/5SPH1JZdWHfyDe/QCZ\nBqSZOFPyP2pmVe8EGbZTBG0BH54a+asEqBReaV/N07BRXAeRsGCn7afSDhzg\nAq0qHr1FNW8w9LHUmaiIa9YK1oLDlYPGYPDVlmmyNtZym6wzHh7QFzyyqkvx\nOQqd4TgLg1HGLURJVjRAi5AWkmQhoDPK8AWVVkVjTztGZs6+GDJUIq3b5MaJ\nfxPniuqQrH1XnI+Z8Dk8ESC9OsLoYGCfPlA5vK9s73Pu8BODhUCFEskrMLG3\nKCcEhyacFXZSXE2+prXHGrTFJ4aJEojSwRUMvtNUdO2XF5/5iNNFezZOZozy\nIXFJ\r\n=d53X\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCkzF31WAilo4f+d0AgL6xIemIs/BOcXMqY2sz+m0LyvwIhANPDnjnqhOZVB8cdgg+qAQVX8CZELbJ47OWqQzfuDSxP"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.15_1588347816763_0.49392386895173157"},"_hasShrinkwrap":false},"0.1.16":{"name":"@mgfx/task-bull","version":"0.1.16","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.10","bull":"^3.13.0","mgfx":"^0.6.4"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"126cc3d108107d365904499131d18ceb558ff99a","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.16","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-5lW/6zlVFwASPnmD9n+HwFjkvsoR+XTH9pzBqxVIzmvK5AUI2gHGi20KwKIc+XKoIcCIeiGDk3HkvpTNM1H+2g==","shasum":"3f2df2c870bda800edcbe22abf8076a46cd7e117","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.16.tgz","fileCount":7,"unpackedSize":12160,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJerEnQCRA9TVsSAnZWagAAApoQAIu3fHncgQfk7q2b1uhH\n73R/h2/sAXycuql1Q+CeF8Ay6OELE/2D4F4GanXZhCx3+fF9SZmUXvlr6veh\nE13IZOBU13rEI9QhgR0XWATZ9f5DjbbLBjhzBf9ocy2JFfl/AWDNzUdrAd8T\nYBD3IkiIaZrLZKC1VVFdQ8z7SIwtAgn0yQoSy8OZaWYFJ7P2sqgARYe4RTfL\n9NL2FrFy26sO892Ok06NaFY/FKkn3UPYRPCl2KtNVUmU9ThwjxwFbcUV4R0J\n1FvwNGeXle2e4V9rnhfZA9QspaPObz/nDPau23fwOhXKPJXJUAZo8FuhGEvb\nY0surMDzTqsmEZjDr82hBGIYdt+0aAsTMjbIPLeZgQqse69IentkUNqpQzWV\nHGn08DCvn1OsMehjwgRxqziN0xZaWg/t/3B535DlzRxJiz1ufsKZlnur8yA0\nx5zmYCY5z57SjUD0WffE1HQ09S+/3XbCILrBIH7lUf534/WLZT4uYskLijDo\nE9T9qGvUxEUb9I0VQ5AIfAPezM6oSzfoXZuN2528fgPvyeg1khaevAs20F90\nOrcTndDa1hH42CdPMlMMJ9xFQYYa2h+bd+OVUWf7mIAgnaESY1woZh2oW2M9\nWctTugJ5u31t7ACyOY95K1RD6x2GvWNAjjIMrdJuXp7KEVmnLCPBjsTkbHq2\npf9e\r\n=Dv3o\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIG7BcGd+2CKRzrA0Wzw/CkIpuXcAivRDvj8q18h32QdnAiAGg+b4nuBW00lFAUzvhkPB09BYaG99TBlw5P5hxXyqXQ=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.16_1588349392317_0.09523658639735544"},"_hasShrinkwrap":false},"0.1.17":{"name":"@mgfx/task-bull","version":"0.1.17","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.11","bull":"^3.13.0","mgfx":"^0.6.5"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"45d90110f854015a3024a73d0db9c0ec32185d27","_id":"@mgfx/task-bull@0.1.17","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-ZaRWXBeP1Fhd2K1nLfrMEgMUBFfpiPf70g4SF2utO3wUrtOIW1NO7QhHy6LiSFU7i+UGfoUinP3C05mIbQBFLw==","shasum":"76c4990e1f5136e1fbee3f69fdf9036a05830c27","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.17.tgz","fileCount":7,"unpackedSize":12245,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJerFEDCRA9TVsSAnZWagAAe/4P/0f3QHB7ad8KsGeoL6yB\nn/Id/n4JDQPnafEnRmCZRsY1AVldU4JgHD0pwM+ly/zxI9Qy0qVFlfPhF/Tw\neZKCIZA/CqmczE+J1dip11LLk0H2zBwRdOQv/f9U1C+xgboLBMFDTEucoNJB\nzgu8x71mEbZeYVCpxL572MLXk/bwMtK97+54JjScmQkZAoVR7WzoattbmEGO\nY/Qj840xQ+YQ6EeMnri8+xxSYya3Mak6vcEPSnfYtEj+NtLxtfCheDk2/p/H\n8H3lHadpZiCbnx+i97r7HAx05ITkVq6nBPJ02OJZjOSJ6BAVcs9xDijcoDHa\nJ2zH5tkcFosLj922e46bR2SwpbvVyJXYtX2hmwYriGCkLP1spMOwv4VOdPjK\nrV6DSvHubXqnG6m/yewTTNEyJ0n8Oo69bu3oMalnrc1ZcgU1VOYocxWujeQV\nSVQCqCojpWNeKf0/CJgWqomnAc7tq1ab15iceVQfTROFtbNQUUeyu/VdL48g\nR7XGVTfLpjKMd0WFlyNt2ngVixd19SD3J/KFYX3ql74IN9Hq74BIkMrYFb08\nIcN02d1NDaGtxiv8v3EyTYFX85xQR3Ty9Slr9O30fqtUtmhm9kCA7IFn9z75\n0pcMGG4KQlMQs+P/g7+dDOpz8bGvz9JhAPnWmaMb5YzcHIzwLPNHUD9KIk7F\n23ud\r\n=RRFE\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCtEavycAAggnSywdKkltSkHwN6Yfurk3/eKTwyeKIG8gIhAMPhN2s7+VUAcL12wcy4JlX4XGWEmBYB+BUOyH1MSffx"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.17_1588351235166_0.2936888923022263"},"_hasShrinkwrap":false},"0.1.18":{"name":"@mgfx/task-bull","version":"0.1.18","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.12","bull":"^3.13.0","mgfx":"^0.6.6"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"df9fa5589e4c78a1e69000b2c9b294833287b320","_id":"@mgfx/task-bull@0.1.18","_nodeVersion":"14.1.0","_npmVersion":"lerna/3.16.4/node@v14.1.0+x64 (linux)","dist":{"integrity":"sha512-IGLWA97kJ5xYuNqIIbMQXNvcieZ7fuwD/L4ZqpGVuNOVG/T/TmRqXNyfTFCeD/NS8sHjhKkEi5VIZgk8ynPkeA==","shasum":"f2c03c6068eef2e07830bc4184af0dad50a11f62","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.18.tgz","fileCount":7,"unpackedSize":12330,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJesYSbCRA9TVsSAnZWagAAdZIP/1E3404ltf/L6H3N7CHu\nq/Ur4A44fCb0XQA73nPaAY9bbm9siuycetYgdFJ3c8HXQPh+0UTL/H2zzFtz\nIbWmFcd8Z6JH9KgnfFNqEd1n1S7kyYMWF18CfM2a/TyaZJW1pIAYrjR4S5EA\ngQcSGvCxcHLUNx8paqtaDiYU+qkk1sr4zLOgbcH8ZzyRaprrr+9+n7wOGgZ3\n/DOY6m9fJvwrW4D3yOhvf969zJw6BxTfJHa3TaXL9SG0xhbP30Tu+eBpUOso\n5tB+Fgq/+8ND1ImV7fiSt7jPI4kic5zOqrsCDBzANX9mr23O0vRU3lJo27PV\ny9Z10nRMFwbFKV3yhHw7mfEeJyfXSee/33+QsLoaYVwdasSdRYNct2uqQ+Ef\nsHZjnw4Vsg+M7pTYMgKJhZeR+GYq+eZdObbJJv4pT3CV2jaHnAhFa0l3cGkP\nUflD+0uhzNGCbiErz9Ar9bVg7vUtCcYUhrvtAARktbL5C9W+w47rL/n1pbsF\nqSB2f8a895G7s5XtBH34kr29BqleumwYZHEmAMe69UPBA0G5WkXQkbF72OYd\n32Rc8km7ghU6y30kJlQjkEEa3AS7GXwzuT5ohtq6Ty1D8zGono3mDcDfs8ro\n9PxN/xrL2oVsmNJf7XVVD07n9ERrvEM+HQ4s32o30rG9Or/jnDVgjUoPZA4T\ndels\r\n=rh+I\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQC6/g3E8Lp2bkoRuSKqrubMAgk/5ACOSEr9nIBeThi6RwIgX+q+CBusKA3x1+dABBnysqybdqbGZHfT0Vc/BMU2dIc="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.18_1588692123234_0.7320246686139227"},"_hasShrinkwrap":false},"0.1.19":{"name":"@mgfx/task-bull","version":"0.1.19","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.13","bull":"^3.13.0","mgfx":"^0.6.7"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"727554a4f702a9c468e3fbb4b823ebc9ae45e633","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.19","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-MaEMkW4yTWXQgpsWfBDGvi4SlbL9+au1Jn65CS9ScDf+X9bDOZzmY6YbO8ylNONY8uSiRPseHZvADXxunEGuAQ==","shasum":"3fb70de964000442ee6256043db7e32dc7a21109","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.19.tgz","fileCount":7,"unpackedSize":12415,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJes9yHCRA9TVsSAnZWagAAfmEQAImh1syOzcjCSekXgjMr\nw3RaCeHNbNSd6hw7+IhVFy+XAMY50+wuaobbMT9RN6WYEdGw4YXKRzNF3uFs\npRhfRiknH+mv8OeOiRjohqDhNpbOX2azN4MPWVIZyaVlBmf5Slp/U28FJfqW\nbRlijnPeC9D4s3K99FX1LGG6T5bY5zkXmSrZoq5OTF69WN2RrlQBTYS1uxI6\nORmL3z8RUFhA7CCDKc5xS/NvjnwrYkDkBf3qBaUG8L9a/1GBZn/vwPeGiVX9\nzXHWPp7NGC4Roj+hIeiEZgrhPlWLdtLDJPvnXJHaV18mTGc8UFn9jNui2z0x\n8xdtyayXi7qt6gtXHVa14BgBD5SSLMCLZvWnfCt23u0rsAEBgg1dq8xNqDLT\n7AhgTG8dy6EstZk6g+LRqTmuPuM3/OLdIOoOJeDzpqJvuE733xb/psdLgng0\nmFt1LtjFcATSTCb7KKuxwo4nzUX7DpHUDH2M5H/wdTNf2gBvGw2VaqfkxzIJ\nUvzfu+Bneil6tXhYWVCqXgaXsxnESg48AmgtczgStWvJHbEkO20VOmmpRv3/\n3ieqUmAqTXgtR0vIEMXYVGSlnVlbEH/7lbhLsjr5MXLgPTDKycX1+ArtKuNI\nqSoSV4Ok9TrWveoXrkwGTRd4n561aPyHGcNE6YKIbWAQHCtQsHj59y8Fti+b\nVi9f\r\n=7E4H\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD0fakGWmARYdxCBUWTAhvTxW0FG1ooDyLYI5pqkBPIGAIhAPLzz9kQDyLXc+oTeXWXtiEL7bAmkfipIH3YCWxpsAhr"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.19_1588845703486_0.874607651375279"},"_hasShrinkwrap":false},"0.1.20":{"name":"@mgfx/task-bull","version":"0.1.20","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.14","bull":"^3.13.0","mgfx":"^0.6.8"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"2ac179b7b5767c471c90d4c43dba5840313321e2","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.20","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-MNKeL9qOv+3JeVJ4RHB8zkOYozB8+5v2t1xmp/wcdaOSsEHQVEeWBoaIUpYQy7e3LalXSmDKDeKpXGIHZTOslw==","shasum":"28507ee6b7d28342c0089d991e9d5ca2b846edc4","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.20.tgz","fileCount":7,"unpackedSize":12500,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeu9K2CRA9TVsSAnZWagAA2GAP/AlR45eYtaGZtqIOmnFV\ncmNxb7ld4VTtmnGdxUHGNsLITr3/8ebKbpwYAi4WCzkjjqwZMuhLy1eBBrYc\nIN5/kmlEjd1LM/TNeKMSYiGS631H0tCR9q/C6Fyv/7fdVwDD7nWnIJxpDYFW\n36yxwR91tXZ5FRmjXnXLbEJQ+w7OOwmrZceW60OQwc8ZbIfwye6m60Y9eX8U\nIQS5WWGUeDO86/y9U4QxxZYb3fDAkulTG4vuJk29e3Q3GQQtN2xMwTvXa90H\n/47nGdKsDJC6E2b+EywEMyPrANdT0JbS8FCwVrcHz7PP2DWMaUwgTGhfoX7u\nWoMRMXS8ttY/q99XEIusMPJa9PYqoOXeB73r/QTnOiwoo6HD8KoXfe2S3OYS\nhZVVZsQtcroYKNtLPdKnDTwArbJV4/UnjH/ipFzSbPzPYibAUjqvWDNqWclw\nAvh2GBLrxiraTcPsdI7pZT87pNoJK4ipkEFmsa6zOYpRR5EPNLbUktZYKbJ+\nNZtzzvOvEUxx91sznV/tNxpHA+/2qxrtkJq0SjMPjxVXMnckLfgRb6WPSS6O\nz0dE/IbujHg9w1YQmHrkQc/gqBloaqYJEfW2jzexjfSO/aqHg/ZSGk88Rt5k\nshnmDQnLlvO8uWaeefWz7wldhcuzfreHrhfbjTlfPBHK7JY50XM5nCzvx/v4\nt3rJ\r\n=rUOY\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCmTdCNoc5WAW2PXRe8IjRgDj0LXCEA5VJPVNKfGZ8iMQIhAPZdVdk5kX1VyjUDRBbW3ssKmtV0uQU0bbP8meThPPQG"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.20_1589367478212_0.31492756705165315"},"_hasShrinkwrap":false},"0.1.21":{"name":"@mgfx/task-bull","version":"0.1.21","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.15","bull":"^3.13.0","mgfx":"^0.6.9"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"ad1b585f3a201b4a8a2d3fdf97c7ae7a3e9c0a36","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.21","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-ZdZK/zIGA/K+h3BSZkwIlCUfNDKGHAy9AcHewzWXYvBmTYNpoEld+X/WWY+WyY0scJS31ZBe9Fsl+MWM9tyJEg==","shasum":"81140a427ea4d036fbf0671071af28eb7dc860b4","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.21.tgz","fileCount":7,"unpackedSize":12585,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJewl0MCRA9TVsSAnZWagAA8FkP/i9BWuLGGgq+DK66Fu11\nefmOT7VgQ6Sli5WyVsao9uLucaTBbWa+JPZGUf8n3aCJ26LF7WGC676t6sP0\nWjJ4UrkF/64h2FWshYTOzvcquOKBcCdTGhuZY8if+93dHgom1ZqrKACQQhe9\nWFAgz3yiqE0u9G5CWqDpxqyhaAhzaFk6/iuuFeKx6IygOsg1yC2SDOAn3KVU\n3TmtkN4c+GlsnNPxDX1R8lDdybqjwOE1oWZ2nKeKjzF63eLSHJrxQkf3eyIH\nzJaugfPSUhVbaD/Py81bz0uYnRWl+psnD704CWHLjARazFL3RriQPFBhWwd7\nJGVRFTv7FH/cRJwnIJmcnx9ZmR03WRUZ5I91PlGqdSWzq6yUIauzu1WXjfHY\nB9b41jCfW6paET00s+jkAChLCmZPFtM9KOX08DJvaALwiGwm3SP4/1TAEAc/\nNX3OJu3CzIaB6AzTg2m0dXwESKW+v88Ln0cqFMf7Zjcdlo4Pj/dF4RWsK34l\nAIiEDD5EC7R6lJfw1RnrDELtPmJYuHcW18/YkxrfFI4M0qMXxoMJJEcQ55y3\n9BkK4P1MJC0/I2K3aOuLU83AcYDqjKo5aejy6LzWynIgJuh8g3Z0u74fqZ2u\nLfzz2Y1MbhH1/Ayld7re6dQ0pB7+wVvgO2Sq5jqGBJD8z10Yd1Yfhko4z2Fu\nbkxB\r\n=XsIk\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIFA/v7PSK0Em4Py1G55wUfEtfh5Zeip9vmYccasYqJ2IAiEAzoc+Q09cweNNf6X3tuYuDkCbOpkwaze+lhJ9FH0Xygk="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.21_1589796108228_0.9465145861784074"},"_hasShrinkwrap":false},"0.1.22":{"name":"@mgfx/task-bull","version":"0.1.22","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.16","bull":"^3.13.0","mgfx":"^0.6.10"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"39e3c702b5c04c072c5e13056833c3e841d81706","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.22","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-5gjdecFocDzeq0AEND0q1bsMic6uj8+152U/RFbszI/c+8a2lHXZYmlO0wMupaWnEUeyd862ePTdar7VJgTvcw==","shasum":"be0c020c107701998b7d0c2e3a9bcfa05abc36b7","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.22.tgz","fileCount":7,"unpackedSize":12671,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJew+MnCRA9TVsSAnZWagAA6r0P/imW9bpLNCrdbWBvs+13\nCmRZasUrjhJlhvavHnSEt9ulvmeiP/WBIcR1JmFRTwAwIf3S7UN0qZYSlxcE\nnLbo7RIaTrDuY4AFJg2l04gR0KhwGnRzVFPAOkzWH47AH5pA7PFA3vxoq6Du\nKpX8q2kSbKUFv5PaVR3DXy2wNHL2hW8RxClSQMTfjkfpeQQ9TILT4LoRaSv5\n8vPibks74U4FR83BFTBJqPufpX2X8rYymlv35wwU6gtdkyr1ZsQLK7k+kBcg\nqwIIVUt3N6opgd07SYSqXP7qCtMg6RQQ71xq1hy235Xh/kV275rkYQtuQxei\nk3iHcPR09zpiMUgSh2+I+O2+OvrCLZPzmNa1aFnCS6uOb91W5FNVTG2s9OH3\n2MWRZlI7fTtAIs/OWVa4XIanclaP1krsAZFOQwZmqpShUfgNRq8ZaDEpt7jz\nghEGTmM/UXVSaaj5ScIo+Qdy4C2sZ5CBpqUPFvfKTaIxl9FXnyEpWAZ1bIEa\nPhYQZc+ks02lXdcmbrHxzC/oEFbCqayo+kGuzmCHXQnySX/OeVo/GgXcdtk2\nPvkWFfecxph0382odEncAFiGVaeMyu1yw0hUBDWf0424E7fRekgHGKIvSYas\n+CSjWzYi8zFStx9d3BvoaNBNx5s7m7M9QeF7Rc2ZCTck3j5dOL9W+qNZZF8Q\nlYvW\r\n=S2kf\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIA8teOQfjJpDOonN+i4ocHR9IAWhnFSJGtWRBT80KLThAiEAgcpgVQaVQf3uDI+cgSsvuK2h91ss4Oz7aHMnPKXsaXE="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.22_1589895975172_0.9453208578215426"},"_hasShrinkwrap":false},"0.1.23":{"name":"@mgfx/task-bull","version":"0.1.23","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.17","bull":"^3.13.0","mgfx":"^0.6.11"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"580f4eec1e135c346013dd2338b2ed7cd876ad74","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.23","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-S3zOfax8kYJuW9bZZLwoFCrGpvbB+1eYu1Fe0i6/dv4V3Nob65TfYklDHbZz/p5jEm71TaxlLSaw9M4eYq62pQ==","shasum":"765d55b119e10147439a1aa20f4d45aace34373a","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.23.tgz","fileCount":7,"unpackedSize":12756,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJexACNCRA9TVsSAnZWagAA7C4P/iC1/LyLGOEwfiOBoVlE\nlTYeZBDtNj7qX3GrgkAuIeNLheQdfm0Y2wMDMc7FCCUG3cMPiqqN9PRpEdaU\n8uJ1rloAey7EFoiZdagluoB81des6l3RiEDE6mZBhC5KrBQcSoaoRRAiYPVx\nGDe6q+p0cBvqXrzfqa1uyTVlUAupsRhnip4fmHXbpcLU/57er20HQkgfziG1\n5uqD+IFT3KqMG7xa+0A2HD2NQsvOJ0Si6WzY9qWOgKwBnaV9dRQEB36BCMoc\nVz5xr1XV+21tkq94e+vXiwlHP2p7iUIicOu3K/JlC+vUH61aE17bWSmTXTHS\nuZ0LaJ1h/lZ8n49wEnEW/5c6Eo0NL0Hbfato3Jj93HX2N22NDXbpI8zSRELi\njRRzR9l2T34Rc0b8zT8z3qZkGta14D4w4DwFpgJ7Jr58Q0z4KD3/a9ABFQK0\nHGykO4YcPzNeIiVudhlSzMYxUFuLe5f0S76V2EYwDIUYfowu4l9gRWzkvDPt\nUDJRTwNf+tRwknPiWBhxbcWCQLeewjupT2DPyHMEjeNZIlpucxAZfbDjtDWV\nERb8thvTwSny0y8hM/Xu3bZ5104QJyX8ZUVJSZNnk+IgMyMjPxXN3QYsju/v\nukCLOXyW6rTZtVAyPrSDyTCuFukN2qnm7u7dNQwgB1wNBKVqIELmqlXYrp//\nzah3\r\n=gbE5\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGTQCixSKLlwdAY24XmnQSPxtLYLi/mqOudud25wm8QKAiEAtP0dYEy1Lkz+8LefAZ1wv7L1m9UunxDRYRZ21Zh8T6U="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.23_1589903500690_0.6602956145448029"},"_hasShrinkwrap":false},"0.1.24":{"name":"@mgfx/task-bull","version":"0.1.24","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.18","bull":"^3.13.0","mgfx":"^0.6.12"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"20d5b8a8438c93289389b8c4e7914b7342e4e387","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.24","_nodeVersion":"14.2.0","_npmVersion":"lerna/3.16.4/node@v14.2.0+x64 (linux)","dist":{"integrity":"sha512-xSRdm3UilcVAteJEOUrOEtPQPhMEdze9KBlsGAcbPwHVheAYqC1OJcsDe+q/35SHW4/houwC5Kk0hi5tusRzdQ==","shasum":"97fc8c4fd15475781475c8c90a783ff997cf66e6","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.24.tgz","fileCount":7,"unpackedSize":12841,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJexoNECRA9TVsSAnZWagAA0WsQAIyTIS8shcHFdJzonaGP\nWSuajGQE8rp5RRxvjYbquJ385vsB4WJUYwuG3QPkYiPPr/NYjtsE9N5M/t/s\noJEgpc7LVzQyVjmF8Aw+j8HWpbs3EvE6oqwDZxUppDFnPDDEJ2Odd9FoHSyw\ndrWif3sDl/DA0CbyvaaZqB92qwrWnwmPU7w0fawqHRsUKYVxGMsvBRnne+6i\ndS5DJzPThV0gbNtbojdo40syp7YNLzdX8DNWf+bJY8vSb3rK19tpG3E0hwhd\narcMwXc3fyvLzcZtm1tyR1dtJoWvEMN7op4HNFdxArnAN66DymOe147GciH1\nI/YfvCvIUbLman/tcR5K/Hvf3wANXteYRtTEMqflvGb1qU1iCDuHjX8mlups\nGP0Jonms28IDOAXt9YeoX/9PI9V0EbWDJCk+UwjJdknLQR8pYqUyYMjvIFGq\nx4JfScc6GXC1PV3yFISDgAmX3WQtc2rk4gg4xPbopH9GGQV6fJrPj5Ptxh1G\ngtu8gqrW5oXBr3+wl+oJVEczQvkA6YBqCY3qxHf6tzEQxXO55mz0icD/fAVP\nMXczOmO333oM8CfGDivKrJPCzcC0pixesULa3gUTmH7fR4MvqWPbkRrTPESJ\nfm5R6F8CCwRA5leOOgVcsg5Ucq+IZKDFQdwyiSKOmo0vwH9/kxDaNT0p1HrI\nodYk\r\n=yPf+\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBd0maWvtY0jKvQDCXXAUj6JMtJS1YsLcv71n18CZqxaAiBckS/azwGHu3G96X+pPuFwYuZo/Oa8gQqy4OzTpZ1lkg=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.24_1590068036135_0.7169186907338776"},"_hasShrinkwrap":false},"0.1.25":{"name":"@mgfx/task-bull","version":"0.1.25","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.19","bull":"^3.13.0","mgfx":"^0.6.13"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"d9792140e08f621c3d28ac8d62377644097db638","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.25","_nodeVersion":"14.3.0","_npmVersion":"lerna/3.16.4/node@v14.3.0+x64 (linux)","dist":{"integrity":"sha512-wyl3eMInUSoI7YvHgDxFANuMOutsy8k3V8RybqeVsXVOTu8rj+Fd1c+iByyPa2jls50HxWGKLReLFtcRRtBdSQ==","shasum":"371a73e4f53557a28ca5c72081bb3f9c5318d9a9","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.25.tgz","fileCount":7,"unpackedSize":12926,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe14nzCRA9TVsSAnZWagAAOOUP/iwCn0u8umHBe5odJWFJ\nK+Z1x7ov/s2HlCyWnxmT8fivN0qJNX2WGrxBzuekSOM+4lFVOK+rs1sUt78Q\nWjWwQHe/crzB53HKxlCjyKwnhpZL2LpoTtXCoi3IYbHHU4nfd1+DMTZIn8VO\njg62cJo+dXly052pYFH6H9KozHL35+k4TadawnBhNPKgcshbZwSujdx7yUOw\nVPFAjKtdp8u/tY0N9Ro17nRE/IjkjsZxhrJs1XXZsq5f8EaOURMIod33QmDE\nEO3/bpAVsx9LbXnWaaf7UE44cx443qvlB1lwAitEf0U7jq/ZNJ/aZlnm55Ys\nL661r9XP6M3vvQDecIfeHZahrP0M5sjG7kkItn0Jt+xspEv2msVFeY1i91se\n8xvPO372Fxr6iCEz+N6D0CXSKt24jTd4MgdPx4GsROwfOz/WfU0XtxWxzxl7\nOeu87n3BrEnkx2/ksYqnK2nFtS+DTQRs8eJT+Jt59Z0kDzsHixkNtFFvKAt9\nCFm+wG0ffCz+GtsA/EhBMQaBOxNfcb0/eZ6SQ3JTpYUBmee70OYNU6EV7PGH\nrbKrFUZrZlyfl3N/muo6F8j53YDFfDgy4sWSnCM0uEuKB9CKYoDeCkQUDSPX\n7wev6YzTsK9L9u2tcBg0hgi22Tg1sAprVzlf2UwV11rgdPgtUkibcylUDmBE\n8MxZ\r\n=+4F8\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC8T76+WGV57J5BC/ok1S6lWx1Fsmvye+yZkVNVKu4UxgIhAJe9oDuuH9kVjici5F5RE+YLfCdE7CFGpRaWkvzunRt3"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.25_1591183859189_0.5372401571408194"},"_hasShrinkwrap":false},"0.1.26":{"name":"@mgfx/task-bull","version":"0.1.26","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.20","bull":"^3.13.0","mgfx":"^0.6.14"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"1e6eb6297e11dfc5c67051f120f4420b5e4d1d2d","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.26","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-lryeA4Ki3aTMWycb//YK+3bWq9eXE7Pb/k/vZlxNUv1jPx+QCKwObM8uQ8iw6tksiHlK+2sqtztC0Md7HrrXUg==","shasum":"0a846c3927fc70e8d6b97784de40d74d790d4d47","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.26.tgz","fileCount":7,"unpackedSize":13011,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe9NO+CRA9TVsSAnZWagAAlJkP/1YvJuqyGvWTp5qWC6VZ\nmpiZBr1BYJxDJp3Fu5HJD5BSM5WHAZP8Mt2gDriMTxruEH6hPURf6nH95EUV\nvXjWggkcHlaHUgjtaLc8GZLSy78V2G0XODWXHkQG8VRry2TcyV5U3tD6kubn\nmVCEN0fyTKmWOKALljZfObo7GHI9Xqh/IIlaDERyUxWEp4YMt0AlO5gAdTT6\nHE9LOTrAMnjLl6UadvRnJNS+K4hzoJjLVKlvKW3rY/+cCejhcBWotuhlxZrv\n8OBgBJvTDnqC/3e/87v78gSoGFmv7vVQ0BLIDgdVO1i7D5YVlSYDkL4JFHXh\nenj6848dtjLL5ckBhwoMMyzt30otoyo9SxjgxrDO+ECb4OZ8lu0mWP1or88w\ng7+hMDDWgE6iMYK6kBmvxb2RBEw2VMf9apycM0KBt7HJLbxBFeKz/8kwD693\nxkYzv7PAZqHhuj1bONMm99h9qQQj5YWuqHghu5gSjTAoqNu4gQEdc/goUN5m\ntWd+rlvnWZ+ad9eBa8Q91oV6jQXb7vJ6HeJcoTYp3f8aqVmVFzpW9hkF/+P1\nTNjjk3qjXhjPEgVCDWo85pzfiN5oHKqo8cAcDqzIV8DGms5JbXuMqG1LzwXS\nGlEtDIHv5CxqBhcKX/+6DsonHrRJmn2HOKqFhtFHfZdVSEKMN4SqHDwMAK4l\ncbkU\r\n=7N0B\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCPCGAg5Yok7Xv8yLKzxiIcdvtyy2kMB6i3bAHypnfJNAIgbyRfPiaGsrxau40DSAJNf/+1mdeTE2bAtebdk5+bxYM="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.26_1593103293982_0.14753161936315973"},"_hasShrinkwrap":false},"0.1.27":{"name":"@mgfx/task-bull","version":"0.1.27","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.21","bull":"^3.13.0","mgfx":"^0.6.15"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"7aaf043b9c745f39ca971ccf1d2f0334d5956433","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.27","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-qm07O46CyKQmC4VERBLl+gUbOhacSjNif3PCjrwJFg1jmdz271C6aDzZwmQBwgSkHSz0W1WxBn7skHCNqlab/Q==","shasum":"bddd349750326f1caa24dd5818b65c66a7640124","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.27.tgz","fileCount":7,"unpackedSize":13191,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe9No2CRA9TVsSAnZWagAA4AAP/21RLKqqK7gI9g3UxWkD\nAKiQD9yk1WEKkkKDJdYyrWM59W32Ie27wNsfDGGLfqd4VtsjY9YwfRd8rFej\nZVoN3pr7pmdlel9qwYtVkd/XArHYk8keddc3rJZcPjfLRLmIxGIj5FvXJTdq\nW4dbXUAUumUbV3WUHKrpXl4wg5JvOF7uH27+A1LSSIxNpkRpT9wAl+ZaiW1i\n15gyqXU8vwCYcBYS/v/Tc9feyOsju8DZncXId/G2yP1A/J7tLRTr0YyH5MBF\nudD0PSFO5SXOGVWzu4FhYx0VPaa9MKKJ5gfQNB+7ca2TRI33/t5cFQECOrSZ\nPkEAHCJL14GMVHP4Tm82IZ33w450EkjCL8wD7x/k7K26R1l3TVGu6QzOkrLb\nf1bwHpin3ZyIX03USz0kRvH7NQftNwnqYzOIovU08mtTGsrbgcZqcnxdjRfj\n92rQFllWlL8KU8oP8BW31Q2RuNiglB8m7TOfMdvpj/ENLnySkT9xsyStRFfn\n7bEg/ytz6fVqrLt4MkQ9ApzCyBqrZyPhnl3rNqoni1dqHIPFSV/K3Dku+Uqc\nulVKIx7eWTgc3L45MNnA6P5WrUh4sRmpvUrOyhpplUhFg9nG1Tdix1W6lvTr\neaoV72dCtlLxjDQPHThikQwDFdsErUTTswI26SJ0o/kaeWAEbnKYETp1czHj\nMPVw\r\n=gdGM\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIFF7wJm7mUGxkx3gRAf3ktRXDjELa3JEQKEMIGo8ZePcAiEAzMbRAcqDIMtkb3ZLdjvN0ILjmwmG6BlSEthW/nkZ+no="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.27_1593104950406_0.3496132059895609"},"_hasShrinkwrap":false},"0.1.28":{"name":"@mgfx/task-bull","version":"0.1.28","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.22","bull":"^3.13.0","mgfx":"^0.6.16"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"174fde2e25c2f6e3eb4934b382a589fa79e075f1","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.28","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-rXT1Fw1TuDR5LoGWx+E6xU+BOab3lNL8fLoUpTGYUsJ/pZqC5MYb/kL+d3BeiwzDyyNhl9zs7l3qide+Ewns5w==","shasum":"96376276cf2597fad48882cd0d933625302dc644","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.28.tgz","fileCount":7,"unpackedSize":13360,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe9OD7CRA9TVsSAnZWagAAQYkP/iFBo01/Bh6UiFljQShP\nMyDCM1IGGoxWouSLY7PsJVTtaHQitegJl6G0VqUiW4L6rgFds13HA8OnPYxw\niqwD3OhV6FxGJQ7VmkOAiO81S78mjT+Lo3wSGOlaIZnkZIrwCKmwQJXkNqVG\nAdRXa5z3XGIrgTlymzS7h0BLR5zfDGr5aVzafMZAe4ctWegG4/o2gyWy0JYD\n37d0vy8MT5XsjssFhG5qRrca6dZj6IvzvYflPzJjgzbimZ+7JICtPvpKu4AD\nGD52UZU3nXE1jolMuLZ8DQ+csUIlkBJ6fjrHSK+Q7bAKi4oevxOYirMRisG+\n2JYl9Qc03EioUeDcxCynBalpYZyMl8N8NBNvLDxOJTue0+1wCOi2DMogK7G6\nUGrmYbZ4Ka69UB7Dz8SmTTHZtbGAtnofXHwL9tRaoO4+l/L3Ac78lUlWtXYx\nPK5FizjMDJmNOxaTGOf/lQjkctsHNtfX5LxX7GG6UAOvjh8bzeERuiREa+li\nKxx+mMOiG4bfr6eFXnHgge6T/kwwxw5j5Bn+kpvhY338SFwhP4xTWd4ibreJ\nmQgsXwNiFYU+xiX26s7y8kSdXUrT/o+BzcunniMVsSmrFAdnc9dftjnoxb00\nvPwumD8NLUMcUhl/DBR3MIf8tNjyy6w8fBipWvvzsecvaG2Jn9F0wM+jQ3tG\nlhNF\r\n=42J1\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAn7M/nU/6Y+Au/GG3x9t+UEpzK8OdBQez77W9oUT/u7AiBY7VPcnlJQCVgtfqQLoBEJaF+UL/Puv4ZkLmI5F6E9Yw=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.28_1593106682934_0.36191215431704116"},"_hasShrinkwrap":false},"0.1.29":{"name":"@mgfx/task-bull","version":"0.1.29","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.23","bull":"^3.13.0","mgfx":"^0.6.17"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"0862590f6e66813aa6e96824c96265e809086826","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.29","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-G52YB7TKP0nDQT8ZXPqG0R5wDA6BeXQ2MDyNWtkbbnBqDetKAsBSh2iKlV5M4kfNi2zQXUkI1C3aC07Qo/+MjA==","shasum":"b71246eae0863c90daa46621d4f8bc358da5e0ad","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.29.tgz","fileCount":7,"unpackedSize":13445,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe/JRKCRA9TVsSAnZWagAASecP/R3RhndsMuKOMrJd8m1p\naSMrBgn2Lnr1uJYPgx1IQ0mMb8by4Uj4hFseTJb1v/MPOLY/7VcEtsuiCLXY\n7SqTlC5eIzzpZlN1rdWiV59DUheuQ0NIpr8dXlPuej0QBmzx+4romantpZi5\njdw35j1TR30VBPosGF/w4y1G7WnqqEIBMbccDmAtN6Oe/KYVpWG/qWnlndC9\nnlTJwEKqs51W0PVz7GvJ1XshAOVO+hCkKdkX+sAiNQ7AjrFT+XN/0fIEKAQY\nxxcLttKNiGQGTnAufIihPLZHzIiYtccm3zb8fyYs2bGnsj8tEJAVowwtXv9+\nakOeDXxRhVl66a+CSAC6GwbPCIYv08ZH2SGemX7g6SkxhjGWYoR6wuyChxSm\n/NfFM//FWOHoBWK7rtHwVXl7uLNF0PgIxwym9PH5eZNPw2+cOGql2mCMWnH5\nntQ6yqdXCF3vxSKnm6iJofp9Et+/UPGKGzyH0D3rPFKxwUwKgCcVy3WNzAoN\nJ4ZktUt2lbgP6LNGjuY0CeDbRA9AH7WX2gIUdH2JWIpP9PJErQ0zLHEDGyS2\nT/hETWiUlWCLTQf4vHKEDMSJTX+tMhitdQleoeyE915TrqirvzBVVU1dFG3o\nl0KnVkHT6VLDDoa8NYrH0Xb0jiBdhVI5XXZ0T7SPYNCR3GZDJe0loc/SCNlj\n8jyu\r\n=rY5H\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD2PZeK4d9rbEtNxTlvaRHdOPkYhh8wCuXRNIaHE63DbAIgTxYL1VPbWi509+AHlRUjhI+WRnpH9/NUNX5PCALbcLU="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.29_1593611338056_0.5892957536261345"},"_hasShrinkwrap":false},"0.1.30":{"name":"@mgfx/task-bull","version":"0.1.30","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.24","bull":"^3.13.0","mgfx":"^0.6.18"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"266a80eb6c732e83bde49b6de17fa8190cd7ecf2","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.30","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-5f8XOGD3I6f2aEEMDZeSmQNoxHJykkmzG9M5EOK5m9AlNtQiiJcOZcl+9zZvVnDF/2QufmEXWEscOK0mmONDxw==","shasum":"3772faaaf55aef0a0430c73b9fae585c9a4b4d3f","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.30.tgz","fileCount":7,"unpackedSize":13530,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfAyW2CRA9TVsSAnZWagAAFzAP/2nq3bHQuOTF+nJ5MmMw\nx3OUoemjpFwVeDuiTwfgSc2T0mjBNjEpa0z0HDGYDTH9hCHULweP0wE6F5rA\nM3zkn0txKxnixD/9pZkyINvNZUamd8bITjN23hOMWokEJUuQHptbHUE2qZmT\nU/yLHDusp/wpzGYXr6rWS0RG+GBlNmnAxSLzZ1Qsj+LowTYXeeTGzg2DEKKW\nG1Qz+Hu0a9wVZU+n3KhdIGQbYHhX2BdHno0HG+YFpBF5yQQDcbjLPLHweUZ6\nmUUg5JLGNlRWu91JhGK/nPG52VziXDS7eXWqd6ptxsGQcA/yo9Az4tfO4pgb\nbxBFr/f6y5n8yPj+CT1DTX1VlJx833mwkfFK1i3qbxvEO/YIxgv7Sfxb2lcL\nuMLzpZ2KFt4/gQMNS8YaR2JjyqRd7PDRCGBIt2i8gx+oxwdHsWxNb1fW1+vS\n6hZTKGRZ8yJLH+PlrbzYOT4k4PKXLjNVwQSigzuXyn1o6grnjY0XB0que1oS\nMUjS3rMOm8aSeJeBsVjg9lXJvWKr+0bFd0jnn/9KdvORSG4mO+rd7E3x45ge\n+mvX/MA4UEI8dr+RG5qiY57gkN7IbJ3VrIATrmHeJW4XMoK6bkf4iSndBsW4\nCl+7yJewbIUem8jZEApFmuI1zutiLOpXZrX0YU0zoUhlp7p9YlXtnkYwz299\nYy0E\r\n=muj0\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFNVreiJ0HSLomnvm7qq2RTjowa2aa/gDnOaNEbEKTXrAiAklKVgmSUpUWB3TF+1MAIq8PwYD6mcS9MsqJSYMExVPg=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.30_1594041782328_0.6982663239421536"},"_hasShrinkwrap":false},"0.1.31":{"name":"@mgfx/task-bull","version":"0.1.31","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.25","bull":"^3.13.0","mgfx":"^0.6.19"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"9ada6758610d76e410135aaacfcde1676f1e1fd2","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.31","_nodeVersion":"14.4.0","_npmVersion":"lerna/3.16.4/node@v14.4.0+x64 (linux)","dist":{"integrity":"sha512-rkZegcAJG7g1P2zfGw/aWCzboBTC5AwtF4gCf28MY828w5Mgq3RsC0CxKSvTSVjgv91e2iWioie7xrKaJYDoNw==","shasum":"4a0c7daf69593fc63669025ece598d825c4baf35","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.31.tgz","fileCount":7,"unpackedSize":13615,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfBcDVCRA9TVsSAnZWagAA3gQP/2arrUaO/qw4QwD18qfO\nVGbgPi7PB8eWlS2VR7WgJr61CzVVvkKFHP061ae1jupPb+0Nw8iWHLLCZbIj\nO+ffyMWLypFHQWHIFdTRiZuCqd0QMAIFZfGXPwsPPyvzrbt6MR0ZvF1OoxVj\nBBolYvI7czmI+9jzUerj1PGRzHBopFrTB6j8NzN+ZWULVB8FjYm5L66y/FX1\nFymA2nCyz1fGTSc5qx3QC9qV+WO7C3KY0POn3zKOz1JkHNDZ8nFpO3euZSOM\n+1N/t0RfaKHFQZImXpLgfARFRXdta6DomOeCQdUBBGcVXbjDCSDs8LFVJ8UM\nkCG5wdFbGLxUbbcT3tjTL+MlNpkwfC5SkdOqUzULq6D/uJjdiv6tEhdvwMYZ\nxKC0046/ZgODBmOCa7SCDyZ1JRken6AYff9LSwZ1GO2GyO9I+MWWX+yIE9d+\nw27cFVDHxEuKHe1KcxulkEtMjFR6HtPIlNQLpcs5YJgJ/lm43wMBSsraip4W\nQ0Fffr/O6wCVSDEIGGnqpaa4+BvJQuqHVqxvYqI40PsyE4eDlfoECkSVFwcv\noxdCYK6ePUtwiy2v9ak32/sjYsaVx8ttsOk/gj00zjAWJXSf4yZSom5bBQPY\n8yV1DLTBs4mSXa6v6kjJqqHLF8e1SkOenlnON1mi9NtXOYo+05/EDxZv6aQN\nw2vm\r\n=IdDI\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCJwt55mA138sorPm0O1CbSIfxHaa2C7hvh9046G9fREQIhANqu+cySytTZbdTwOmCIgg64ba88n9xu3D9aVsFx+m4N"}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.31_1594212565317_0.7651656852907465"},"_hasShrinkwrap":false},"0.1.32":{"name":"@mgfx/task-bull","version":"0.1.32","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.26","bull":"^3.13.0","mgfx":"^0.6.20"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"68db2cfed36ed56332d4e4208413312dfc827e0a","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.32","_nodeVersion":"14.8.0","_npmVersion":"lerna/3.16.4/node@v14.8.0+x64 (linux)","dist":{"integrity":"sha512-ehegKrX8yYeKqt+YVwi9JxrCow52zxwyBuISKvMhRXMXDZw81FeDhbDIaYBPrng9pri3VICRQcYX6DgXI5PbQA==","shasum":"80dff96885b7add4e5df6c378b4e94f7da3dbafd","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.32.tgz","fileCount":7,"unpackedSize":13700,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfPmWmCRA9TVsSAnZWagAAQLkP/1zRMabp960Jzittteyf\nO5W31ccMPaJZTgggB7VtKRvglZFE3LPY2alAksGnf0ggSeDM+Fl+z/hzOcTQ\n/mDs3GzS0PdaFX7Obq+mdy+dQZ1f6XFlueUoYOMNNUXqzdmBTJLEKKXlWguo\nfuOr0DRl155Prakp6U5YlEboHXLw4harIvHQ31j4XJyzzzHF2U1RugvO/IN7\nAsV10e9Z6kzqB2HAYj7VNzOTYjG7D4hFn2SiK6GPo6Wz4jt9N25W7SSVPiVD\nu0SCKY7LH/JrWkX8F+Py7kK2572Rt3gyqaH8O/hI6Ni/pBHtqV0JmrsbQCuI\nzx00mYQFF1iD2Fd/u6WjmQZZme9Fx2l7t6Tz3gdK/vM0HmWMRNrt8Ek+nwYD\no5H8j/XJFch6YpgLJKaR5h0PThsBfRgkHUpRZy0+rhzcoz3JQs7aR/d1Y9Wi\nOuGFHV1MbqK+sBtnE3Ft00mpvB1qFvQkQgG43KRt8iUqQGbADnYAo9fBGfGF\n7tDvL+DO/Lc1QnC7xd+srrbDUBbG+KoRIBr8ZZrYbdllzEOAJ7r/zJ5yhPc1\nci7WEOpnSllSLb/ZhkvV7akogVVAM/lTFQYKx5VargNmzbQEL5mUu44VW1k2\nmhMGT9JtX/Ox+yv0wxF4v9TVWNDyaPYMtLD1PeAXG7gXcMdDcOjQq/RbteCV\nNWbk\r\n=QkGm\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDF7q5LT2nI1+dbaVMOJo9JKd4n3tvoyUG0nGySfScj5AIgaZU998TMx2d0xe+6kQ/zpuPUnLz/KDZnc7DY13HrA7A="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.32_1597924773789_0.9194025196224762"},"_hasShrinkwrap":false},"0.1.33":{"name":"@mgfx/task-bull","version":"0.1.33","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.27","bull":"^3.13.0","mgfx":"^0.6.21"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"1802d9733b8dc735b2277dee6f92dc0f7f24cce4","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.33","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-0pOm9z0+/pFTGLSuezQdC38RONld/PTHR/Khyxjc5vL5SfLsb0JHcC7DKyBfp9UVP7kFBDgkbl562kdy4Iy30g==","shasum":"dc7488a71344ae771aa91e638300e06aeeab357e","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.33.tgz","fileCount":7,"unpackedSize":13785,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJffs5cCRA9TVsSAnZWagAA938P/Rf8pQZf5FvU7h8xVZ0y\ny/7+IfHrYpetJQdU9Hk/RftF/AwOM9XZT0PUdDdg2pA2s5Tl2PGCecshtZjj\nvuLnFzzbGPopNS8yiOW1Gw/P/Nx4j5AyAsY2Xs2vPGRGZgNv1FHUIDaL4fac\nr1c8Cjysiiqrs6xBlxVm8rlZG4CJSU0sxAostxSxmPxT5ftz0ggJ+zx1C0vE\ng0OihWi9jomn78f/mZCUVhGkOkXc4MXlSBLajIh2vP3QlcfkJspDWWcULjAx\nklDvfPcjStP0Yo2aja1JVjAvSzNJe6h4OGlH3hQLKglJE9QYwEhxZk8llZ8/\nHb8qhanFcH97g1YpSRg6832st4Uv9YAF3WuHYex7elcTIQNf/yITNhkwKhpx\n2hdL2ZYrg2fM3dwbO9+Yi3WH5/JnSMi0uVpySw+EYL5N9h6f6g1ufBOCd64F\n9TsQK7hsqnQvEyzS3F2b00y+dSNogOlVpq9BsH5OJ33dt7Hp/OZafyZcckM7\n5s0mKwJGrtaq5PzI5SjYCUCVMkGr2PtwiXMf7RFwHIKxIl7pW+ke3rHSN5ef\nMphlCxrBE49rcFHoxrnTpxj9hszfEYarUPxXeihbpE3n0Ft3nverJxr6wBrt\nHedMWJGrqYNxwVoyFgNv0G/7x6DcfoWNPf/7Vjm8DiTpnZ4k1nWKLcmzjiNy\nKuvO\r\n=RiL9\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIGjM0/m+02/VcUTUsKwddYsntDKhlk0W8M79zwaSQMoJAiBs0HBEmHBg079v6MWjf5+s0XqDCzjjoXW7Z6sAuY/ddw=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.33_1602145884219_0.845426827494536"},"_hasShrinkwrap":false},"0.1.34":{"name":"@mgfx/task-bull","version":"0.1.34","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.28","bull":"^3.13.0","mgfx":"^0.6.22"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"c0a3eab21300e508c235ee0b1ad7ae157ea1695b","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.34","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-StLeLVAfmjmWNcQeCc7mQufLRkK+aYLkaT/ZfihFCU5z9ttMs9YYyandZD/X7RgfPDrDLQt3R0ecyAylN6kRLg==","shasum":"ce0dcd08fd2f632afea1cc0cdf433a2a43c85454","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.34.tgz","fileCount":7,"unpackedSize":13870,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJffvJpCRA9TVsSAnZWagAAdO8P/A1O2jirZCdxwbz5szBy\nkPuILjcXQno536hiy18qAOeSSi0AZrCdnRYcmyO0zY6v5YMaY4e9a0t1EV4c\nwwBwGHxI7o93Jw+nt6l7aMyUCCnwI/BbxhjYJLAPUOJlEipTQGB3FyElGdNC\niqUZqkPTPw75x2gkOpk6RvlfBR/0vzqfUX3V75q+C+s/h+IvNicGAM7aZZMS\nI/tX4k2Gv18lGkOUreAxfdT9vZR4ftvLZV65Eot5SA9oNjx/EWnQEb2vZXdi\n231QYljHQNMYI0aNYILj1TtjfGIrG2mFjM5awlM2hddRu7w6JOpeBkoQX4s9\nEBHK25oOw9UhPfQdynqjvnI0k2BN+du6Tg589h/DSa/WvrIxuv0rtZsO8w7c\n/9OeAb8PQUedneGYac1pe2+7FVaspwy+JAQji8jLzWqAmxD4C0X26+T6q1Na\na2mwG/S5WB4vCpwKoooRK9ZbqxluwBC39+/LcDOh/OY/W+AFl8LO4wAuDbob\n3lyp3y20R0a7YcJGLpivFbrh1NJdDwoSiZT/s3thaG+16ZzgCZZxNLuhqUdC\nAvrPBVLi3bMr/W7hwsf80ztjDuVYUov1qPGWVx7LaKHJcnEp10QsMOidztGa\nn+HhG3JOdeMjLw0QTPTWOygw3Z13xOsu0vD36qc5gBN2irRWRyVuZN2c27D0\nOg85\r\n=rTyW\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIE0f242Rbk0BIokSZWKYdqnnQyLFiux2qSN2mfrlitCQAiEA0EpR5wwdcZMey6odW0LSaN+x1jT1Die+k+4vjE5X5os="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.34_1602155113127_0.5322846178628695"},"_hasShrinkwrap":false},"0.1.35":{"name":"@mgfx/task-bull","version":"0.1.35","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.29","bull":"^3.13.0","mgfx":"^0.6.23"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"143ab624cb2475f3946f067462a5869d2f4b0a5a","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.35","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-KgS2xeZH1knST80RjkKKEYfFS6yvGZ/rC7AOO8yoGqvAgr9HB0YjllZ6jfYFYfigMlOTCFGTvm4V32Mbvrof/Q==","shasum":"90e24b870db7e94ef8e268d0361559fa4f0d5a3e","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.35.tgz","fileCount":7,"unpackedSize":13955,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfgCOBCRA9TVsSAnZWagAABgMQAJ4P1uX4J5gpqET1qhEO\nCmr2FVb5MYpcaIi+rHQFwLJ4arPIE4mKGXfjePs5h7L8KcLvePPYK3HUSdCy\n22XVn+fW55hZPbg5rngdkV6GBrWqkzsJvsnyoY5zu5shKtRGh8I5ZSyBwLi7\ng+hMHYsU3cbGGZKJ445z64wCowNJ2oCFh904mfa7d8OYeB5ILCjOknPwyadJ\nz3V6LBHabxRvEoSQPVO+SysDM4blkbppNE4qADJrD0ikgt3peIEnH7Yrzzed\ny/mf1ys+6BJiKMNhg4UYjtAmGOzeQSfKjVmBRA39MlUAro5Up4TdNNLpms9U\n12nMpZPaZlAYZl50sHsAwEuTQJnxy0QKf7XcSccjfnkHldwxxV847ccZUl+R\n+L9VUPTMQeqjgSKRj6DvTeT7joU765oNjVO1yGo1ApsRODuVtzTFS/ea+dBZ\ngNvZjr+idMREdBrPc2+w2rtGZ1MzCZ1RN4Zqn6tVh1gOXXdAQ2lTue2poxNL\naHS5tqAS32zTe8RcP3Ps42VLPxt7giQzuEtPneVTJgMregRBNLErrG2Erfnz\nEaB708hJHd5yfcUCMTA4lIDf4bMZYhy7sefKHDrTXz4oKJzsGG4hfopPtil+\nqX3A/0z1snsyKwFkCgDGZT3jfvwxH/6U2v2fr0WiKmfnpDbd+psJeU55nW5+\nmNcL\r\n=UCre\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDFt6b6e8CvFHuMgZVPZlJPj2bKteuYaL2PcUUx15BxtgIgRqvQzWaObB/8OjJyJ4m0vyGsI5WSCkjXv8XElQxsc1s="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.35_1602233217005_0.7923590805432557"},"_hasShrinkwrap":false},"0.1.36":{"name":"@mgfx/task-bull","version":"0.1.36","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.30","bull":"^3.13.0","mgfx":"^0.6.24"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"9616dc9e215bfddc790e2e0aeaaa0152396c4deb","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.36","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-Hq+8xktUFthJbO08H0t54Ati8HlGmrSTOdLpd5fM+5PlVpZAi07rLlwfHrtmNIyQodiQuSQF2UDBvIwgGI2Z1A==","shasum":"17e1b26ab5a2071f9a32cdb58320c7a2dc77551d","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.36.tgz","fileCount":7,"unpackedSize":14040,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfgDECCRA9TVsSAnZWagAA0UEQAJmW5lpglEFrss9lggk0\ntoDsjsiZg4WLivzlymlzvYJrOEWcNaDP7YV7uzQrsjNxxjprDtdCu+S0QALu\nYE2otbqigZ3IU9zzw57+Pk/wZpQqT2HlSRpYaHB/eB96WbQBkSZ7iSc/UY67\nDO0Gfx6cM7MgamALrd7vqGzvR2lsdrF8XaBmzXHiWLwYXW7+PoQqU8b1VNHb\nML/DiUOlbuztB5Lbxc00WxD0W1vJ3k3AbvFx2J9N2DByEt/FEmDBbElVHtb3\nh0MT3UBXx1PVy6dwvwX7Fi1McoDG/m5oz5TIik0NDx8T8Eq97pI7Aaw6gtmQ\n8pExN75M1Y94atOhwIHyd7MOtkzi/YxCFgy5yRO8jgpzIUmLYBEF4YuvACP0\nJVxHVNfEV0LJ8j70sSXDIh//uHPp7T7EY2mHfkkUVfNhqWHSY1XheoLAM8AL\nHwMAS6N1nGJzaDRNlUR4MnI9rmfVQvhNYaZDdFSH0Lf+wwGyOY8W32bO7ZJD\nTGIc5pgS8WvT2d+tVjG623P2n6rFFTErT8/7l76MtYvrJTz3U4jEphDuhvml\nxnM/1ZrZP4mkIbrD8chowd0zPb12R4ZV+8GzW3bIST6wur84NUMBlY5fR91+\ncKl2vtRIaYmMeYF7h1t329Id2QF9mi47gI8wcvbP8TZG9yKumBlnTU2StzsS\nC58M\r\n=k+T3\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIG5RphAoLP9MninsGQBWl0Jx7LqXu1qMABQl41KmKQzyAiEAjB89iWhFrSI4CNT5PukJfZ55QE7wJzZv2l01Iq3nS8w="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.36_1602236673683_0.19980826608349767"},"_hasShrinkwrap":false},"0.1.37":{"name":"@mgfx/task-bull","version":"0.1.37","description":"A generic mgFx task definition that allows you to run Bull Jobs","author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"homepage":"https://github.com/ai-labs-team/mgFx#readme","license":"ISC","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"scripts":{"clean":"rimraf dist","build":"tsc -p tsconfig.json","test":"jest"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"dependencies":{"@mgfx/validator-iots":"^0.2.31","bull":"^3.13.0","mgfx":"^0.6.25"},"devDependencies":{"@types/bull":"^3.12.0"},"jest":{"preset":"ts-jest","testEnvironment":"node"},"publishConfig":{"access":"public"},"gitHead":"12d70abf1762db4c26a657739c7eed5974d167ed","readme":"# `@mgfx/task-bull`\n\nA generic mgFx task definition that allows you to run Bull Jobs.\n\n## Features\n\n- Delegate a Task's computation to existing Bull Jobs\n- Gain the benefits of mgFx's Future-based asynchronous behaviour\n\n## Usage\n\n1. Install `@mgfx/task-bull` into your existing mgFx application:\n\n```\n$ yarn add @mgfx/task-bull\n```\n\n2. Define a Bull task using `defineBullTask`:\n\n```typescript\nimport { defineBullTask } from '@mgfx/task-bull`;\n\nconst videoTranscodeQueue = new Bull();\n\nconst transcodeVideo = defineBullTask({\n name: 'transcodeVideo',\n queue: videoTranscodeQueue\n});\n\nmgFx.serve(transcodeVideo);\n\nmgFx.run(transcodeVideo({/* ... */})).pipe(/* Fluture.fork, etc */)\n```\n","readmeFilename":"README.md","_id":"@mgfx/task-bull@0.1.37","_nodeVersion":"14.13.0","_npmVersion":"lerna/3.16.4/node@v14.13.0+x64 (linux)","dist":{"integrity":"sha512-Y5TAATCeg+npexCs/C6CYDIAznJunIIWqZXlYLCbCOYufi3GFEpQEBz+uW5Kfphalz5YR0hsnwEMSRXqOK9HgQ==","shasum":"e71d2fe82726f4e5686efa767471336b8c54993b","tarball":"https://registry.npmjs.org/@mgfx/task-bull/-/task-bull-0.1.37.tgz","fileCount":7,"unpackedSize":14125,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfgJTzCRA9TVsSAnZWagAAaPYP/1VUxXkSxREDH6fcDUNt\nWQ2T0Tg3HwPKQ7O8dxLPED+Sqaflk+TfUcFWnq87l8OQJs88qJZWJXn95bV5\n/p5V1pyPh/LbEGns3vpK0Q1WtkORn1ZCRt54CrKp6+i42ax7coSbskvusr69\nL5erZr0E3ifTSrgfh/UUVyKCXbeF4PoIX0c61r3RixTj3HQruLWiIgefkfLt\nxeQfFeC236dX5eM7FJwuJErpBX76avlnUPn3q4+zwEdSGkyFDySOXMQn+7Ip\nXwbxgxHENdXow5+cq5VH33oYawfHoXdYy8UNJq+GbW4j4iMYf53AOhWeVzZ0\n9wz2P+Wx9dQIb6v8S+koUzbaf/04WZkVMbonwMU05XOAUW5JoSKTEQsTudrL\nJKWuGEaTJ20jZ0BpSWc0zZbp2PhroYQKw1TNwIGc1Vck2JkN3+xjgzHfSKuv\nCcD2cHu1F2Rl+qZPdD9d1gRMV1tnU+a+gtkYjKILehWZHv0wpJglLDOKF63M\n7+PAg6nK0Hbz7S24P1dym89VT6p3iHPHMKX0l4jrpBVPLrZqKpiJyhqrsuDK\n5t90T9bXoBezthHsAErqNe+Vs+EGiUpgTY2s0ppnw5dhYu5vVmmTWgv1+SF2\nbifa5vGzWuz4nbQkdSqlbS39f1Jr1c9TJdziZxfHDKpU8VsUYAzvAhnPZTWI\nDg1v\r\n=nkAm\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDSjYNw7RisV9vdzR/XJKhu1F0YjOASdLp+TToCxcX1HAiAQQCnnqv7KKNXCRZ1DWqieBn92zHngCyAVCGV2iU62qg=="}]},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"_npmUser":{"name":"warrenseymour","email":"warren@fountainhead.tech"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/task-bull_0.1.37_1602262259088_0.3077811286494876"},"_hasShrinkwrap":false}},"time":{"created":"2020-03-05T12:24:12.957Z","0.1.1":"2020-03-05T12:24:13.259Z","modified":"2022-04-06T05:17:51.492Z","0.1.2":"2020-03-09T10:12:14.977Z","0.1.4":"2020-03-16T15:14:48.741Z","0.1.5":"2020-03-16T18:37:09.775Z","0.1.6":"2020-03-31T10:57:47.774Z","0.1.7":"2020-03-31T11:20:35.306Z","0.1.8":"2020-04-01T21:23:11.591Z","0.1.9":"2020-04-02T06:23:13.571Z","0.1.10":"2020-04-02T06:52:15.790Z","0.1.11":"2020-04-02T07:49:23.000Z","0.1.12":"2020-04-03T13:29:51.080Z","0.1.13":"2020-04-08T10:04:46.787Z","0.1.14":"2020-04-08T19:01:30.274Z","0.1.15":"2020-05-01T15:43:36.851Z","0.1.16":"2020-05-01T16:09:52.433Z","0.1.17":"2020-05-01T16:40:35.248Z","0.1.18":"2020-05-05T15:22:03.453Z","0.1.19":"2020-05-07T10:01:43.575Z","0.1.20":"2020-05-13T10:57:58.314Z","0.1.21":"2020-05-18T10:01:48.375Z","0.1.22":"2020-05-19T13:46:15.276Z","0.1.23":"2020-05-19T15:51:40.870Z","0.1.24":"2020-05-21T13:33:56.306Z","0.1.25":"2020-06-03T11:30:59.349Z","0.1.26":"2020-06-25T16:41:34.140Z","0.1.27":"2020-06-25T17:09:10.595Z","0.1.28":"2020-06-25T17:38:03.046Z","0.1.29":"2020-07-01T13:48:58.169Z","0.1.30":"2020-07-06T13:23:02.444Z","0.1.31":"2020-07-08T12:49:25.498Z","0.1.32":"2020-08-20T11:59:33.954Z","0.1.33":"2020-10-08T08:31:24.317Z","0.1.34":"2020-10-08T11:05:13.272Z","0.1.35":"2020-10-09T08:46:57.120Z","0.1.36":"2020-10-09T09:44:33.822Z","0.1.37":"2020-10-09T16:50:59.214Z"},"maintainers":[{"name":"nateabele","email":"nate.abele@gmail.com"},{"name":"warrenseymour","email":"warren@fountainhead.tech"}],"description":"A generic mgFx task definition that allows you to run Bull Jobs","homepage":"https://github.com/ai-labs-team/mgFx#readme","repository":{"type":"git","url":"git+https://github.com/ai-labs-team/mgFx.git"},"author":{"name":"Warren Seymour","email":"warren@fountainhead.tech"},"bugs":{"url":"https://github.com/ai-labs-team/mgFx/issues"},"license":"ISC","readme":"","readmeFilename":""}