{"bugs":{"url":"https://github.com/Raynos/read-stream/issues","email":"raynos2@gmail.com"},"dist":{"shasum":"5eabda5d50c66999e89643d394a14fe3d41da9a2","tarball":"https://registry.npmjs.org/read-stream/-/read-stream-0.5.2.tgz","integrity":"sha512-l9v+HFRh2DwTohGWpd4ZOZk+xIBe5dz1o2O8BGFZWyL/O5jyYK/bH/O0DkBcARp5AhhZJybZNoF2oe92V7qRtQ==","signatures":[{"sig":"MEYCIQC6hl2j5oQc6Zd6Qn26I6geirkg8jOjp4HFC1C+ShUb1gIhAIa9jcVL836+WLvWOq8zpMz4QrCo0CW2VJdzgQpLlrd7","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}]},"main":"index","name":"read-stream","author":{"name":"Raynos","email":"raynos2@gmail.com"},"readme":"# read-stream\n\nBase class for readable streams\n\n## Example queue\n\n```js\nvar ReadStream = require(\"read-stream\")\n    , queue = ReadStream()\n    , count = 0\n\nvar timer = setInterval(function () {\n    count = ++count\n\n    if (count < 5) {\n        queue.push(count.toString())\n    } else {\n        clearInterval(timer)\n        queue.end()\n    }\n}, 500)\n\nqueue.stream.pipe(process.stdout)\n```\n\n## Example array\n\n```js\nvar fromArray = require(\"read-stream\").fromArray\n    , stream = fromArray([\"one\", \"two\"])\n\nstream.pipe(process.stdout)\n```\n\n## Example from\n\n```js\nvar from = require(\"read-stream/from\")\n\nvar stream = from(function (push, end) {\n    var cursor = db.cursor(...)\n\n    cursor.each(function (err, item) {\n        if (err) {\n            return end(err)\n        }\n\n        // This cursor eventually has item === null.\n        // push(null) is the same as end() so it ends the\n        // stream cleanly.\n        push(item)\n    })\n})\n\nstream.pipe(process.stdout)\n```\n\n## Example callback\n\n```js\nvar callback = require(\"read-stream/callback\")\n\nvar stream = callback(function (cb) {\n    fs.readFile(someUri, cb)\n})\n\nstream.pipe(process.stdout)\n```\n\n## Example function (old)\n\n```\nvar ReadStream = require(\"read-stream\")\n    // state is a shared object among all reads whose initial\n    // value is set to be  { count: 0 }\n    , stream = ReadStream(function read(bytes, queue) {\n        var count = ++queue.count\n\n        if (count < 5) {\n            return count.toString()\n        }\n\n        queue.end()\n    }, { count: 0 }).stream\n\nstream.pipe(process.stdout)\n```\n\n\n## Installation\n\n`npm install read-stream`\n\n## Contributors\n\n - Raynos\n\n## MIT Licenced\n","scripts":{},"_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"homepage":"https://github.com/Raynos/read-stream","keywords":[],"licenses":[{"url":"http://github.com/Raynos/read-stream/raw/master/LICENSE","type":"MIT"}],"repository":{"url":"git://github.com/Raynos/read-stream.git","type":"git"},"_npmVersion":"1.1.65","description":"Base class for readable streams","maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"contributors":[{"name":"Jake Verbaten"}],"dependencies":{"xtend":"~1.0.3","readable-stream":"git://github.com/isaacs/readable-stream.git"},"readmeFilename":"README.md","devDependencies":{},"_id":"read-stream@0.5.2","version":"0.5.2"}