{"_id":"gearman-stream","_rev":"29-04e7d36368d5f8a7cc40bfefc1d89d34","name":"gearman-stream","description":"Allows streaming data from a Gearman job","dist-tags":{"latest":"0.2.8"},"versions":{"0.1.0":{"name":"gearman-stream","version":"0.1.0","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"git+https://github.com/Clever/gearman-coffee.git","underscore":"~1.5.2"},"_id":"gearman-stream@0.1.0","dist":{"shasum":"257fcc65e128ca4af0ff8daf8a1f896a7f066e25","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.1.0.tgz","integrity":"sha512-143rX2CxRCEOrdl7laTwmXEbV4v7HCfGe1bJYWaOHixVQQ2H1taRHDwDBC3F/TAVAHZAYClEUomW9ykKloh03A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDr+kghaWbfCEFMFHYcJHO2SDKDgf+3FlUA8wRxV3vkIAiEAq/bW56kg3jCLcB/+WcPnZQPc1EUusszwVEJQDhGO1eo="}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.1.1":{"name":"gearman-stream","version":"0.1.1","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"git+https://github.com/Clever/gearman-coffee.git","underscore":"~1.5.2"},"_id":"gearman-stream@0.1.1","dist":{"shasum":"90781d3ddc692def3563bc01821a5b4b0c6966a4","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.1.1.tgz","integrity":"sha512-SDiziGJHJ389vE6eo6u8/8lXPdLF6w4M979OecRsNg8D8P2dtXRJ+LpXcNIuerfT82oKTMBrUKZdv41oYMuoOw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDOuWEGd/XU3fTtOYIew+CIF8KWQ8vnWIWbFyzSuHzPUAIgWjuFAr0wK6LLJ2MIwjN/sGgQrdAG5ywiiO3eJzs0XUE="}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.1.2":{"name":"gearman-stream","version":"0.1.2","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"git+https://github.com/Clever/gearman-coffee.git","underscore":"~1.5.2"},"_id":"gearman-stream@0.1.2","dist":{"shasum":"b543dc0f1c3879fbed652dc9a6ffc2fc78a9e4dd","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.1.2.tgz","integrity":"sha512-EYdcLiU0apmi/Ngy2lW8ri62mryyoKQM6xJmNjjNUN16nr12NKYKhoSkdnsXklIgZ/0ubZs1mAwe0zMriqb/iQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD95YUhaaPVTweVoNQiKZD8BdKHnCia9FE6iy1Uw9HB4gIhAOwBiWhqH01bMHUu3IIcvJtukeBdZirTm39F5nsn69A0"}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.2.0":{"name":"gearman-stream","version":"0.2.0","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"~1.0.0","underscore":"~1.5.2"},"_id":"gearman-stream@0.2.0","dist":{"shasum":"fa177d38e05a414b11d9f2ad4761cd73e49a3bdd","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.0.tgz","integrity":"sha512-4mRq9mUZYC2/Weo47h0NctyisrNFmPLaSMvaesRq3iL32nz8ThIdudlFlw+VcA20Ob25Nwm9F8vhH66cJ/ruWg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIB7E/2pkthOCvVyWY/gFvL6+FdO/scJzJFjkeN27vMmAAiEA543JEzKup/Pt+jPjRzea//+XvU0aPi6JgpLcD1Xvu3Q="}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.2.1":{"name":"gearman-stream","version":"0.2.1","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"~1.0.0","underscore":"~1.5.2"},"_id":"gearman-stream@0.2.1","dist":{"shasum":"9b356d02642acda3e1a2987947e21944a972fe86","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.1.tgz","integrity":"sha512-2ykk3TFn695Rdogj1xqghrmHLuC4YddOCrIPYTSOzUWLE+17lcA0FR7bxAMStUZJq9RLHKFGDZcm2QW4QaYafQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDkvRd1IrRarCYoqeX0PqIVS31loATNJKhBRizJx3p//gIhAJ6Gv9E6rO+b5HZXWWYQyHkNRYZ0QofnJZZeEEMQbUUh"}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.2.2":{"name":"gearman-stream","version":"0.2.2","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"~1.0.0","underscore":"~1.5.2"},"_id":"gearman-stream@0.2.2","dist":{"shasum":"205de026167336c41a8ff062a8a7037ec23bf0dd","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.2.tgz","integrity":"sha512-uk/qmbncctvIgmF7/KKT6cGUmoGvgS/TDpxMEibxukv8k8SEipIHyk+6FNO+G2PGb8VrG/+byYIPNA8TIbQOPQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCJCt+MLGslsXSMf3GvioDwvPE6+e/obthr7F3YeTSnLgIhAMaawL8Y+Q+FtJHStJH1Hx/9afwJYhg7PwFeeyGzAVL2"}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.2.3":{"name":"gearman-stream","version":"0.2.3","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2"},"dependencies":{"gearman-coffee":"~1.0.0","underscore":"~1.5.2"},"_id":"gearman-stream@0.2.3","dist":{"shasum":"0aa43ac830a60a202f9ad4a966e1984fdbc6bcd5","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.3.tgz","integrity":"sha512-18wYC0A2VE+3rjdkbs/MrrppKYX/Diit1WFNeB6m1acOh/kmAIurfIzHfZhaVExZgSHbYw1eOPaBw3HFLOvFAw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGBcdbBseu3hchFxltxpoDlPpm94tGFdqoXdLDTrwYGiAiEA3f4mT+83hYeEPViC4CeW2kjzSgaYcCPyzbidFGxATdo="}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"}]},"0.2.4":{"name":"gearman-stream","version":"0.2.4","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2","JSONStream":"~0.8.0"},"dependencies":{"gearman-coffee":"~1.1.0","underscore":"~1.5.2"},"_id":"gearman-stream@0.2.4","dist":{"shasum":"c30e7dffe4e09395c4cf827443c381e2dc1ca8e5","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.4.tgz","integrity":"sha512-ojd0O3H2JRXIWl+FmfWNxp9ILU6calV8V2INuoTmoaNFwfnRp8t5BlPsGoiKeXnfJOBwbZR1tocMhbJVj40tFg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIGiqriFANMgwrhwGDKUWO5B803XNIGvc5oneLGGZk0YLAiAMn0CYLxuwyKEmhyKwcr7Zs2fHpFGApBMa2vTqMqYccA=="}]},"_from":".","_npmVersion":"1.3.11","_npmUser":{"name":"templaedhel","email":"cosmo.wolfe@gmail.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"},{"name":"templaedhel","email":"cosmo.wolfe@gmail.com"}]},"0.2.5":{"name":"gearman-stream","version":"0.2.5","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2","JSONStream":"~0.8.0"},"dependencies":{"gearman-coffee":"~1.1.0","underscore":"~1.5.2"},"gitHead":"f1d13bce053b3954e39ecca38b35e5eda15d19de","homepage":"https://github.com/Clever/gearman-stream","_id":"gearman-stream@0.2.5","_shasum":"4b0792d9d0a3e9e0acb3415c06a4a1c08ec04593","_from":".","_npmVersion":"1.4.14","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"},{"name":"templaedhel","email":"cosmo.wolfe@gmail.com"}],"dist":{"shasum":"4b0792d9d0a3e9e0acb3415c06a4a1c08ec04593","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.5.tgz","integrity":"sha512-swHw+SIdr7KB59varwGGnOMeaIQ2LA1Av+FYxgMkWRbPkTOWF1JcIGzE0ffVpnw4KdAvY37x/AxyWK8TjlCBtQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDrPayupOIwF1IQ2dLhOoA/30s6rIS2hjBZaxqv2afwXAIhAI+1vKlWxxhL4gGbsVdqpnUqladJ6ACnXJcfpdh/oa+l"}]}},"0.2.6":{"name":"gearman-stream","version":"0.2.6","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2","JSONStream":"~0.8.0"},"dependencies":{"gearman-coffee":"~2.0.2","underscore":"~1.5.2"},"gitHead":"80466c7f134d41d414191a4451477dbd14a67133","homepage":"https://github.com/Clever/gearman-stream","_id":"gearman-stream@0.2.6","_shasum":"4c2cd644da64ba1c5f2055af0dba8af923a2a8bb","_from":".","_npmVersion":"1.4.14","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"},{"name":"templaedhel","email":"cosmo.wolfe@gmail.com"}],"dist":{"shasum":"4c2cd644da64ba1c5f2055af0dba8af923a2a8bb","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.6.tgz","integrity":"sha512-sfJ4zDM+iEJJdesAefGudE57SYI8E5+PXSKpjHKJAR05WQNjA24E44VIVCV2g0852UjHFgEPowYX0mqIT2MF6Q==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDFCOb893Eoa+r33J/Znk/0OdvMiwv1GgSwTba/YzfpbAIhAMwMRO5E73EnxPU6+PwARDTvfViQGIBLRojZ0qlWldWM"}]}},"0.2.8":{"name":"gearman-stream","version":"0.2.8","description":"Allows streaming data from a Gearman job","main":"index.js","scripts":{"test":"make -Br test"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"keywords":["gearman","stream","clever"],"author":{"name":"Clever"},"license":"BSD-2-Clause","bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"devDependencies":{"coffee-script":"~1.6.3","mocha":"~1.14.0","understream":"~0.8.2","JSONStream":"~0.8.0"},"dependencies":{"gearman-node":"^2.0.6","underscore":"~1.5.2"},"publishConfig":{"registry":"http://registry.npmjs.org"},"gitHead":"a7b24f0c34eff73adc719dc058ca0263f50b6b60","homepage":"https://github.com/Clever/gearman-stream","_id":"gearman-stream@0.2.8","_shasum":"5d3d45ad04c830196c63c828629494de079ceb20","_from":".","_npmVersion":"1.4.14","_npmUser":{"name":"azylman","email":"alex@zylman.com"},"maintainers":[{"name":"azylman","email":"alex@zylman.com"},{"name":"templaedhel","email":"cosmo.wolfe@gmail.com"}],"dist":{"shasum":"5d3d45ad04c830196c63c828629494de079ceb20","tarball":"https://registry.npmjs.org/gearman-stream/-/gearman-stream-0.2.8.tgz","integrity":"sha512-8GFyE/3TpD17S4uM784jUdEitQJhqzsAQgqN26hez2WdXGaOGvHNUA1UIArwGZouAAeSI5/20WzeeZsQ/42f6Q==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHeMAQk/HtGWrJL+CX7VyqnkGHO+KDKozzu5AibDYlfnAiEA9RMSTa3DG4eYc/XXRGbho9RpjmJFuFxMVuJNMrg42zw="}]}}},"readme":"# gearman-stream\n\n`gearman-stream` is a stream that serves as a wrapper around a gearman client, allowing you to stream the payload and any worker data.\n\n## Install\n```\nnpm install gearman-stream\n```\n\n## Usage\n\n`gearman-stream` supports taking the payload in two ways:\n\n1. As a constructor option, in which case it's a `Readable` stream\n\n2. From streaming data, in which case it's a `Transform` stream\n\n## Examples\n\n### Readable\n\n```javascript\nvar GearmanStream = require('gearman-stream');\n\nvar gearmanOpts = {host: 'localhost', port: 4730};\nvar streamOpts = {highWaterMark: 10};\nvar payload = JSON.stringify([0, 1, 2, 3, 4, 5]);\n\n// Stream that writes 10, 11, 12, 13, 14, 15\nvar add10Worker = new GearmanStream(streamOpts, gearmanOpts, 'add10', payload);\n```\n\n### Transform\n\n*Note: The implementation or ArrayStream is left as an exercise to the reader.*\n\n```javascript\nvar GearmanStream = require('gearman-stream');\nvar JSONStream = require('JSONStream');\n\nvar gearmanOpts = {host: 'localhost', port: 4730};\nvar streamOpts = {highWaterMark: 10};\n\nvar add10Worker = new GearmanStream(streamOpts, gearmanOpts, 'add10');\nvar readable = new ArrayStream([0, 1, 2, 3, 4, 5]);\nvar stringifyArray = JSONStream.stringify('[', ',', ']');\nreadable.pipe(stringifyArray).pipe(add10Worker); // 10, 11, 12, 13, 14, 15\n```\n\n### All together\n\n```javascript\nvar GearmanStream = require('gearman-stream');\nvar JSONStream = require('JSONStream');\n\nvar gearmanOpts = {host: 'localhost', port: 4730};\nvar streamOpts = {highWaterMark: 10};\nvar payload = JSON.stringify([0, 1, 2, 3, 4, 5]);\n\nvar add10Worker = new GearmanStream(streamOpts, gearmanOpts, 'add10', payload);\nvar sumWorker = new GearmanStream(streamOpts, gearmanOpts, 'sum');\nvar stringifyArray = JSONStream.stringify('[', ',', ']');\nadd10Worker.pipe(stringifyArray).pipe(sumWorker) // 75\n```\n\n## Testing\n\nYou must have the Gearman daemon running.\n\n    gearmand -d\n    make test\n","maintainers":[{"name":"azylman","email":"alex@zylman.com"},{"name":"templaedhel","email":"cosmo.wolfe@gmail.com"}],"time":{"modified":"2022-06-18T05:11:27.610Z","created":"2013-12-03T18:40:50.070Z","0.1.0":"2013-12-03T18:40:51.996Z","0.1.1":"2013-12-03T18:41:27.907Z","0.1.2":"2013-12-03T19:39:44.813Z","0.2.0":"2013-12-06T19:29:19.003Z","0.2.1":"2013-12-09T21:09:31.618Z","0.2.2":"2014-01-08T21:23:56.662Z","0.2.3":"2014-01-29T00:40:14.185Z","0.2.4":"2014-03-21T22:35:04.761Z","0.2.5":"2014-07-17T19:12:57.835Z","0.2.6":"2014-07-17T19:14:48.875Z","0.2.8":"2014-09-15T18:54:13.241Z"},"author":{"name":"Clever"},"repository":{"type":"git","url":"git://github.com/Clever/gearman-stream.git"},"readmeFilename":"README.md","users":{"aredridel":true},"keywords":["gearman","stream","clever"],"bugs":{"url":"https://github.com/Clever/gearman-stream/issues"},"license":"BSD-2-Clause","homepage":"https://github.com/Clever/gearman-stream"}