{"_id":"1-of","_rev":"2-562a370b157ca10998cf3f9d2c1190fb","name":"1-of","dist-tags":{"latest":"1.0.1"},"versions":{"1.0.0":{"name":"1-of","version":"1.0.0","description":"","main":"index.js","directories":{"lib":"lib"},"scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"keywords":[],"author":"","license":"ISC","dependencies":{"kue":"^0.11.6","my-env":"^1.2.0","stream-array":"^1.1.2"},"gitHead":"883c7c3e100ff3ce5a060136409bdd29251fe664","_id":"1-of@1.0.0","_npmVersion":"5.3.0","_nodeVersion":"8.2.1","_npmUser":{"name":"bitliner","email":"giovanni.gaglione@gmail.com"},"dist":{"integrity":"sha512-r6y0pHxLh2lE7pEtxx7CntMcHozCEIDwcb4uSwA+z+nAk99/ysQBqBANsIpyT993cspTCJeicCI14I6jsiFevg==","shasum":"2f7ae8396d62929443883b060ba18f45f6034028","tarball":"https://registry.npmjs.org/1-of/-/1-of-1.0.0.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAXd6d3NrImUjd5kUVYtx0kjZUxT85IEghchit/96AtjAiBMzXKhNQopQsCDW5hrEMwFMB8jwRLpACTxpvlYw4fkyQ=="}]},"maintainers":[{"name":"bitliner","email":"giovanni.gaglione@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/1-of-1.0.0.tgz_1504767446292_0.6301688281819224"}},"1.0.1":{"name":"1-of","version":"1.0.1","description":"Build easily and run distributed task.","main":"index.js","directories":{"lib":"lib"},"scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"keywords":[],"author":"","license":"ISC","dependencies":{"kue":"^0.11.6","my-env":"^1.2.0","stream-array":"^1.1.2"},"gitHead":"ecb4eec7a1423cd37fa6ec3080eef6ecbb31d7f2","_id":"1-of@1.0.1","_npmVersion":"5.3.0","_nodeVersion":"8.2.1","_npmUser":{"name":"bitliner","email":"giovanni.gaglione@gmail.com"},"dist":{"integrity":"sha512-3v1ZuOpF2aSEZa5UUz+lQratx7i9B/CAr+ZmVHbXyLGEBgwLkjdv36GcuI/TFEbmIV3WClR6Av2yS1wmw+b4GA==","shasum":"a4898830cf4a52f77b662802a923b8f7ddd9efaf","tarball":"https://registry.npmjs.org/1-of/-/1-of-1.0.1.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQC4zwoY6nyVWsiM3kCIFNhm2GiRgbCExlt0t46XV8AmlwIgCeZegUzMFPCqcyVwxSXBKQki1Sj77tljSmhyWd3/c8c="}]},"maintainers":[{"name":"bitliner","email":"giovanni.gaglione@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/1-of-1.0.1.tgz_1504769196874_0.6737389420159161"}}},"readme":"# 1-of\n\nBuild easily and run distributed task. \n\nBased on Redis and Kue.\n\n## Usage\n\n**Create a computing unit**\n\n```\nconst Computing = require('../').computing;\n\nmodule.exports = new Computing('double', (input, progress, done) => {\n  progress(0, 0, input * 2);\n  done();\n});\n```\nNB: you can return more than 1 result by using progress.\n\n**Create a runner**\n\n```\nconst Runner = require('../').runner;\nconst streamify = require('stream-array');\nconst {Transform} = require('stream');\n\n\n\nstreamify([2, 4, 6]) // stream an array of integer\n  .pipe(new Transform({\n    objectMode: true,\n    transform: function(chunk, encoding, done) {\n      console.log('Pushing a number', chunk);\n      this.push(chunk);\n      done();\n    }\n  }))\n  .pipe(new Runner().asStream('double'))\n  .pipe(new Transform({\n    objectMode: true,\n    transform: function(chunk, encoding, done) {\n      console.log('Result is', chunk)\n      done();\n    }\n  }))\n  .on('end', () => {\n    console.log('End!!!')\n  })\n```\n\n**Start redis**\n\n`docker run -p 6379:6379 redis`\n\n**Run program**\n\n1. `node example/computing.js`\n2. `node example/run.js`\n\n\n","maintainers":[{"name":"bitliner","email":"giovanni.gaglione@gmail.com"}],"time":{"modified":"2022-04-04T10:09:15.255Z","created":"2017-09-07T06:57:27.187Z","1.0.0":"2017-09-07T06:57:27.187Z","1.0.1":"2017-09-07T07:26:37.778Z"},"keywords":[],"license":"ISC","readmeFilename":"README.md","description":"Build easily and run distributed task."}