{"_id":"read-write-stream","_rev":"22-8ac6b54a21f46f905f15430ede830060","name":"read-write-stream","description":"Base stream class for RW stream","dist-tags":{"latest":"0.1.8"},"versions":{"0.1.0":{"name":"read-write-stream","version":"0.1.0","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"~0.0.2","read-stream":"~0.4.0","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","_id":"read-write-stream@0.1.0","dist":{"shasum":"9a6dc5d732701a705813579a70974ba7aae0cdaa","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.0.tgz","integrity":"sha512-zc3hYOC1vCXD0t4nwHCCDUdvWegxE5UJxqkBa9UYrge+AXY7k9X+ul3JrJFb6ReIVrS++5VKTaE4D5SLpUJ+nQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAct+sp6xu1XsBoPVG4fUfFGY3tYMyZmu/3VUE+AeyX+AiBPA86HRIpo00LcV7e1VaTqlX2LKeX0IWPC3ow1rYPdwQ=="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.1":{"name":"read-write-stream","version":"0.1.1","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"~0.0.2","read-stream":"~0.4.0","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","_id":"read-write-stream@0.1.1","dist":{"shasum":"4745ed1e027b4b6b83e88eedac0afa0016c39bca","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.1.tgz","integrity":"sha512-JfUBOfyP7CreeqSm+Iw0Hc+raaUUCLWSAYVP8jynJaxrLw6L8Y/yXLguuytizQ9QKlHwqNdcXg3hrWHAqcGo6A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIB4beMrl9fjX/4mt618gIY7XZCAYz2HiXwMulFGIOertAiBELOfFDu1BrMOPkZqYAkRcikTknv+xXHq8anC2vhBFvQ=="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.2":{"name":"read-write-stream","version":"0.1.2","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"~0.0.2","read-stream":"~0.4.0","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","_id":"read-write-stream@0.1.2","dist":{"shasum":"7f0858c2e4b6057b8d35f9d1b77f1f0fde5f3052","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.2.tgz","integrity":"sha512-NyKNKQKBxyiO8MI/9JsSKmTh/FNPY4TwD9ELv+r8fKai21cPB3at/0cEYo6i1bO5O4JJ3FiARR86yOdP0MpjwA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIC4TSfROdOjS5E+sXtYob1bYvsbj4RW7enHLBWK1eiFsAiAuTY77qKkPEFJ9pfqOLAh3yk/CM+48S14zV6rnG+2cJg=="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.3":{"name":"read-write-stream","version":"0.1.3","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"0.0.2","read-stream":"~0.4.0","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","_id":"read-write-stream@0.1.3","dist":{"shasum":"e4f0996287266962ee1694637fabb6b0b65f5d71","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.3.tgz","integrity":"sha512-sZXqnivnEL4Su7uWHXbAboZZAu62JE5v4splUut7Ncb4Z21AMPy7bOxpbtxkSPCTQCbwrvL4dUpn9Ftjy8nC9A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAMmTyVpfryxhGhYan9p85B+SsLgiRZ0ROO1kNpbAYukAiEAmwsKIDcevD7vvqLtJZy09oRDsEmbTipxTvdgnqvNtJI="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.4":{"name":"read-write-stream","version":"0.1.4","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"~0.0.3","read-stream":"~0.4.0","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","_id":"read-write-stream@0.1.4","dist":{"shasum":"a87427e4ac33fca609b97c491c8356ecf16b3ef6","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.4.tgz","integrity":"sha512-HGmoAkaWmOnvK1YiZKJmzp4j0BvnZAHJ4wa4EDl7XgqhNHYoq4HwNSGb2ONue2Od8a2QL1mUD9qfCMLsuWUhVA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIH1tDlUfHq08seTl5Hr/EwVQ6dMx9S2E2/Sr/cwilfEjAiEA+pPB9l7YSpdA2CiGTu4m2Uyua/UOYTUr4zZdV0tHc0Q="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.5":{"name":"read-write-stream","version":"0.1.5","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"~0.0.4","read-stream":"~0.5.1","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","readmeFilename":"README.md","_id":"read-write-stream@0.1.5","dist":{"shasum":"a4c71f2bb2885911bde7b3a279004fe0eaa64ad5","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.5.tgz","integrity":"sha512-yM8UM07t3//okeAcVKhWq3uW4t9yu052lSSbeaGqk1lKwcJ4ZmN5gxGUvNuFQXu4jq9akGpB5zx7lofAzzpPGQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFOA4nSfahFRC6i2UXNryCwohbaizNPiPKaJvJ0l8hXyAiBiBbkCns87x7gvo9F7SusY+kpHf9BZ3eOpq7nTPhu1mQ=="}]},"_npmVersion":"1.1.65","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.6":{"name":"read-write-stream","version":"0.1.6","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"git://github.com/isaacs/readable-stream.git","read-stream":"~0.5.1","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","readmeFilename":"README.md","_id":"read-write-stream@0.1.6","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":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCyQ1oFiwvfC9uBgzGeAbGcx/utUcPLf84e7k8vKx3WngIhAPALDiZGG7rMtqFUOVvC4lH/dibnNg7SyM4tfc+lEIIJ"}]},"_npmVersion":"1.1.65","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.7":{"name":"read-write-stream","version":"0.1.7","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"readable-stream":"https://github.com/isaacs/readable-stream/archive/master.tar.gz","read-stream":"~0.5.1","xtend":"~1.0.3"},"devDependencies":{"write-stream":"~0.4.0","axon":"~0.1.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"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","readmeFilename":"README.md","_id":"read-write-stream@0.1.7","dist":{"shasum":"efc26e637ce1e41c2ca8e4a69910d3a794112060","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.7.tgz","integrity":"sha512-XP0/BX7oR53Ki8oZbmkr8ZvV0K8ott460l/silKBWZRC2ER0Uj1M4wTYLrpskP8EpGpCyTQNnDxY5GhBG5swGA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDU/qXFonP2/l08ZGoIbKVJDukrSSr7fkvQQwa7JjdsiQIhANdo1ORx23Q451Ak63koGw+Je8qid89LenB98nr9L1Se"}]},"_from":".","_npmVersion":"1.2.21","_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"directories":{}},"0.1.8":{"name":"read-write-stream","version":"0.1.8","description":"Base stream class for RW stream","keywords":[],"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"main":"index","homepage":"https://github.com/Raynos/read-write-stream","contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"dependencies":{"read-stream":"~0.5.1","readable-stream":"3.6.0","xtend":"~1.0.3"},"devDependencies":{"axon":"~0.1.0","write-stream":"~0.4.0"},"licenses":[{"type":"MIT","url":"http://github.com/Raynos/read-write-stream/raw/master/LICENSE"}],"scripts":{},"gitHead":"12010ddf2fdb3decead8d3f32f45bc5f6e02631a","_id":"read-write-stream@0.1.8","_nodeVersion":"14.15.4","_npmVersion":"7.24.1","dist":{"integrity":"sha512-KC4Uv3bZa8QP/ierkRshT2oiv1D3/s7k2/s6jsAjyMG0G9MEcp7NFBf64xncpiy6FLvNW8ePXI8HlNzQizTp/A==","shasum":"74fb4dd125001b9b4bedf7b603fb97eb3fbc35e6","tarball":"https://registry.npmjs.org/read-write-stream/-/read-write-stream-0.1.8.tgz","fileCount":7,"unpackedSize":7600,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJh25ZVCRA9TVsSAnZWagAATGgP/2zYofs9gTmhN3CsH4fv\nrS3Ve0Wn7u/tJNv6AvtwG9mK/fqkPv+cScfO40wicjlJpC2G3LmP20WL9101\npwqbXgjCAstRzct6Qdof8zbAZU16f5fXNNf+uFM/tjDntJ288f7N/ChSpWTt\nDeVqnP/7kD/3LrwNev8FnL5Ilh4xGigrQvYXesh9eYctbaCdKyDz+D+5jbw6\nR34CTJTPfjRQihVYscCeupjarnN65t63sFeLSlkcGy2VT9UOEXlqSRNjyh2O\neD9HlHyKMQaXrxCLfLp8+jWd00ggp/5aT6XgU3F2N74jvdFg/6aBCnpO89gj\n2nyoJgPkBrccvwvqcurQfZjnWD1G83f6RE+9vY8A6wVULg0Fo1zasA+hUTqo\nYYWTJAXvTYNxeliT3HDQVPaUL1caNSqRGhq1/NXApoSKC0YHPp4A4RFzfgs8\nm4uQ3Mi/sinhv0Y/u/2WS4V8MBgsqQnB9CaBHingoO39OsWFE5p4FxqywDAi\n//OoWgqU2yrrkwSAsQa3dSG0dkwYSY1EKINxnhmnORVL1ijLzhY50YAm1f77\nVW4la/yY8AjCXpmyHVtxu8PXP6CzXbSXJweAIGv5J2iVRbp3nZ8qt1ObuEtH\nLKpgh3BLb/sFi0M0Ec2TIGTFnIr+IGUGYHDzfZlfaSwG6gEF90bbCyN7PPAC\n2PSa\r\n=fEgo\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAnVO4/OV4OELHVjpeiri5YNY5Nw3EVEn0Rwx2F0UDNPAiEA5KuI/Qia5hYdYd1kV6a+xPap+QPpytPh/GcCSw9uIfw="}]},"_npmUser":{"name":"raynos","email":"raynos2@gmail.com"},"directories":{},"maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/read-write-stream_0.1.8_1633690206430_0.45186526889924883"},"_hasShrinkwrap":false}},"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","maintainers":[{"name":"raynos","email":"raynos2@gmail.com"}],"time":{"modified":"2022-06-26T09:15:03.496Z","created":"2012-09-27T04:06:09.787Z","0.1.0":"2012-09-27T04:06:11.396Z","0.1.1":"2012-10-15T02:23:46.167Z","0.1.2":"2012-10-19T04:06:53.127Z","0.1.3":"2012-10-20T01:41:20.855Z","0.1.4":"2012-10-21T07:32:46.350Z","0.1.5":"2012-12-03T04:16:27.038Z","0.1.6":"2012-12-03T05:24:15.535Z","0.1.7":"2013-06-21T21:06:01.314Z","0.1.8":"2021-10-08T10:50:06.574Z"},"author":{"name":"Raynos","email":"raynos2@gmail.com"},"repository":{"type":"git","url":"git://github.com/Raynos/read-write-stream.git"},"homepage":"https://github.com/Raynos/read-write-stream","keywords":[],"contributors":[{"name":"Jake Verbaten"}],"bugs":{"url":"https://github.com/Raynos/read-write-stream/issues","email":"raynos2@gmail.com"},"readmeFilename":"README.md"}