{"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dist":{"shasum":"1422292611005f41fb76012a4e2b1cd610107343","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.6.tgz","integrity":"sha512-Dc5fFi29VLqUeZFZMDA1AZ57fNGXkhca/XoQ78dBSRd/ZCUgUceeZnzIdfLorlpD1dYHaIF3O9A/XXWiBSXBAQ==","signatures":[{"sig":"MEYCIQCyQ1oFiwvfC9uBgzGeAbGcx/utUcPLf84e7k8vKx3WngIhAPALDiZGG7rMtqFUOVvC4lH/dibnNg7SyM4tfc+lEIIJ","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}]},"main":"index","name":"read-write-stream","author":{"name":"Raynos","email":"raynos2@gmail.com"},"readme":"# read-write-stream\n\nBase stream class for through RW stream\n\n## Example through\n\n``` js\nvar through = require(\"read-write-stream\")\n    , transform = through(function write(chunk, queue) {\n        queue.push(chunk * chunk)\n    }).stream\n    , to = require(\"write-stream\").toArray\n    , from = require(\"read-stream\").fromArray\n\nfrom([1,2,3]).pipe(transform).pipe(to([], function end(list) {\n    console.log(list); // [1, 4, 9]\n}))\n```\n\n## Example duplex\n\n``` js\nvar axon = require(\"axon\")\n    , pub = axon.socket(\"push\")\n    , sub = axon.socket(\"pull\")\n    , duplex = require(\"read-write-stream\")\n    , from = require(\"read-stream\").fromArray\n    , to = require(\"write-stream\").toArray\n\n// Writable end of duplex\nvar queue = duplex(function write(chunk) {\n    pub.send(chunk)\n}, function end() {\n    pub.send(\"__GOODBYE__\")\n    setTimeout(pub.close.bind(pub), 1000)\n})\n\n// Readable end of duplex\nsub.on(\"message\", function (chunk) {\n    chunk = chunk.toString()\n    if (chunk === \"__GOODBYE__\") {\n        queue.end()\n        sub.close()\n    } else {\n        queue.push(chunk)\n    }\n})\n\n// Open underlying writable data source\npub.bind(3000, function () {\n    // Open underlying readable data source\n    sub.connect(3000, function () {\n        // flow data from array\n        from([\"foo\", \"bar\", \"baz\"])\n            // into duplex\n            .pipe(queue.stream)\n            // into array\n            .pipe(to([], function (list) {\n                console.log(\"list from sub\", list)\n            }))\n    })\n})\n```\n\n## Installation\n\n`npm install read-write-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-write-stream","keywords":[],"licenses":[{"url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE","type":"MIT"}],"repository":{"url":"git://github.com/Raynos/read-write-stream.git","type":"git"},"_npmVersion":"1.1.65","description":"Base stream class for RW stream","directories":{},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"contributors":[{"name":"Jake Verbaten"}],"dependencies":{"xtend":"~1.0.3","read-stream":"~0.5.1","readable-stream":"git://github.com/isaacs/readable-stream.git"},"readmeFilename":"README.md","devDependencies":{"axon":"~0.1.0","write-stream":"~0.4.0"},"_id":"read-write-stream@0.1.6","version":"0.1.6"}