{"_id":"it-to-stream","_rev":"4-4bb93855d795cd75a9fb25b23a56cba3","name":"it-to-stream","dist-tags":{"latest":"1.0.0"},"versions":{"0.1.0":{"name":"it-to-stream","version":"0.1.0","description":"Convert streaming iterables to Node.js streams","main":"src/index.js","browser":{"stream":"readable-stream"},"scripts":{"test":"ava test/*.test.js --verbose","lint":"standard","coverage":"nyc --reporter=text --reporter=lcov npm test"},"keywords":["stream","readablestream"],"author":{"name":"Alan Shaw"},"license":"MIT","dependencies":{"buffer":"^5.2.1","fast-fifo":"^1.0.0","get-iterator":"^1.0.2","p-defer":"^3.0.0","p-fifo":"^1.0.0","readable-stream":"^3.4.0"},"devDependencies":{"ava":"^2.2.0","it-pair":"^1.0.0","nyc":"^14.1.1","standard":"^13.1.0"},"ava":{"babel":false,"compileEnhancements":false},"directories":{"test":"test"},"repository":{"type":"git","url":"git+https://github.com/alanshaw/it-to-stream.git"},"bugs":{"url":"https://github.com/alanshaw/it-to-stream/issues"},"homepage":"https://github.com/alanshaw/it-to-stream#readme","gitHead":"fadd1dbdd0fbef29c99b584e79b039e807086093","_id":"it-to-stream@0.1.0","_nodeVersion":"12.2.0","_npmVersion":"6.9.0","_npmUser":{"name":"alanshaw","email":"alan138@gmail.com"},"dist":{"integrity":"sha512-xgIeg2tHghbW/dWDcr+bZ531lUBowikwlwVL6Si9GSWGVkJT7zf7q+zPwct2QennNzINNErmUV+YxD7t33h9bg==","shasum":"52685e252ea5918fdc542601b6ccd7920dbfacbb","tarball":"https://registry.npmjs.org/it-to-stream/-/it-to-stream-0.1.0.tgz","fileCount":13,"unpackedSize":17497,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdQaO6CRA9TVsSAnZWagAA2XgP/RoZdFS/Q1r0HLJttZyR\nFA6pF/Y2AVkmz6IdyD65k2BIyvhMporEZCwO7neMDhtWQSRB2SU/8EkO/Ack\nBexIsxq4tMUEAu4lkIGCJsKnDQo+/LAR8gaWEs/RfkmZuRcrX2Wj2dNXVL+C\nf6G05cnTwHiWgMOi+9+85nrXwdF5xs4D6jfAIHl6Usk8T0twh1vRMFmXVlM+\n99tDO2kdPuisI6E9alT6aQ3NndJ+4LvslsNJtZUxJdgHRZPvQaUAmG2bNCt4\nTW7MbbWA/As1Nhjn/tvEMdrLYMXZVNML2WhGY1lYy+OCeAy9v7GnhJJZURor\nzK/FfwGgkB6mrfg/HnuA1WdtJoMSh8RlL7KqTBLZorXcJdG6syK3vL04dPsr\n9LJu894HUW0D0fE8N4DIeeVZvtBj2EEmllj6Q7ozNAoTBKCSHWtfdu/jOYYg\nQA8j+9RGQK+96Kpz36SNeNFLFh66SaTrh/Hl9ztMarVGf9vpTshJZMpi7H8P\nafBh6TnLjKsDMIIvqZmyhW3h4nqzipPLbDGYMh+hS1ufobOPdiqJsAWn7tXP\nC9rf6JxGGP540vZf6UImKyqdKfP8tfd67J96c6j8R7O0eXO50J/BWwyLDeVk\nEhdiGhV2w4DOEz3GynVQivpb6QXkMexdvDSR/iP4kMw9zSrjNIqkzPXSkT9r\nth9U\r\n=wCB7\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDlq83A6XlUDiRLz+Qg3G7dF24stwiIp7JOupb0nTkt4gIhAJMwdKy/JFX7EgASwbYD4/Ot2X4+n1c5P3z1NBHkrTs3"}]},"maintainers":[{"name":"alanshaw","email":"alan138@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/it-to-stream_0.1.0_1564582842416_0.40503647996484937"},"_hasShrinkwrap":false},"0.1.1":{"name":"it-to-stream","version":"0.1.1","description":"Convert streaming iterables to Node.js streams","main":"src/index.js","browser":{"stream":"readable-stream"},"scripts":{"test":"ava test/*.test.js --verbose","lint":"standard","coverage":"nyc --reporter=text --reporter=lcov npm test"},"keywords":["stream","readablestream"],"author":{"name":"Alan Shaw"},"license":"MIT","dependencies":{"buffer":"^5.2.1","fast-fifo":"^1.0.0","get-iterator":"^1.0.2","p-defer":"^3.0.0","p-fifo":"^1.0.0","readable-stream":"^3.4.0"},"devDependencies":{"ava":"^2.2.0","it-pair":"^1.0.0","nyc":"^14.1.1","standard":"^13.1.0"},"ava":{"babel":false,"compileEnhancements":false},"directories":{"test":"test"},"repository":{"type":"git","url":"git+https://github.com/alanshaw/it-to-stream.git"},"bugs":{"url":"https://github.com/alanshaw/it-to-stream/issues"},"homepage":"https://github.com/alanshaw/it-to-stream#readme","gitHead":"f7ce5a96976e4abdfdd4359a6a2ba8eda7420367","_id":"it-to-stream@0.1.1","_nodeVersion":"12.2.0","_npmVersion":"6.9.0","_npmUser":{"name":"alanshaw","email":"alan138@gmail.com"},"dist":{"integrity":"sha512-QQx/58JBvT189imr6fD234F8aVf8EdyQHJR0MxXAOShEWK1NWyahPYIQt/tQG7PId0ZG/6/3tUiVCfw2cq+e1w==","shasum":"3fb4a9c4df868cd8f4aaf2071eba5ada5a3fad2a","tarball":"https://registry.npmjs.org/it-to-stream/-/it-to-stream-0.1.1.tgz","fileCount":13,"unpackedSize":16336,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdQcqmCRA9TVsSAnZWagAAY9gP/jUsfiHGaXu/4J78Mm5U\njjzGM4Lxtrt8R1CV1MMOT2kKCoArnq55sfe3JoHLn0OnjRj7VrJl+cm1mNts\n7ytc3cFR1SAwdWtfCPT4Z19DHMbo+rhld8Mh/6nGhELaizXAdr2JTJ+F6cry\nw2l1Jd1pYQK+eqo0c7IUS89J0Q/m/APd4spHGY9DaYjnECVwV04YLxs8ejAE\nU3jaADhfbuMUl6oLGdKIVggCravpCFnJvaKdvFaZ7Szl07br8aYFq/mKiWIr\n0jmajaY0HCDpMtKCBxrlNz4cDtM0kMG9l7+0DBNIHH81Tnykr3562J2XgFM5\nTExtZWgp8ZCCHHk/eMqnQjBH9+pv6dOJy1/0OLdmD15idDEfTZb/9IkGnKe4\n38sbG4JiM94cjIXoQ4ddZjeIUzGfzUiy6yqeGK4Y05Y1v3/hDi3/ISiS/yM5\n8yDEvUtjKypT03y1TruNDhp9WjWC6KSg8KnSgcUBy+0G+DWl6jtVmF2+ynBn\niHwQdBf44pFk2AFBABCypPJ4zTpIiCNx/ISs1vNoBcDX9URxO+c26Rgy6iXU\nT+NR2LQbtOr8f88yrMPMnv33e77SIksmOQdy3wqd/DztHI0Kbi+OWLvA9WA7\nm6PoVsAoSf8dYgfSoOajw4sVD6E0ln/eOP/RP4M0sVFM4V/XyEI9pdsc3+Sf\nm0AH\r\n=MlOF\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBfKY0Oz7oA4SdtZ4YXiysvbWLgRlVCai+tPnsA3oPUNAiBhDcbiJw48+30wOmyJl4NY24xO8MW/rvINe9ZoSOAhdg=="}]},"maintainers":[{"name":"alanshaw","email":"alan138@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/it-to-stream_0.1.1_1564592805736_0.10477427614158552"},"_hasShrinkwrap":false},"0.1.2":{"name":"it-to-stream","version":"0.1.2","description":"Convert streaming iterables to Node.js streams","main":"src/index.js","browser":{"stream":"readable-stream"},"scripts":{"test":"ava test/*.test.js --verbose","lint":"standard","coverage":"nyc --reporter=text --reporter=lcov npm test"},"keywords":["stream","readablestream"],"author":{"name":"Alan Shaw"},"license":"MIT","dependencies":{"buffer":"^5.6.0","fast-fifo":"^1.0.0","get-iterator":"^1.0.2","p-defer":"^3.0.0","p-fifo":"^1.0.0","readable-stream":"^3.6.0"},"devDependencies":{"ava":"^3.9.0","it-pair":"^1.0.0","nyc":"^15.1.0","standard":"^14.3.4"},"directories":{"test":"test"},"repository":{"type":"git","url":"git+https://github.com/alanshaw/it-to-stream.git"},"bugs":{"url":"https://github.com/alanshaw/it-to-stream/issues"},"homepage":"https://github.com/alanshaw/it-to-stream#readme","gitHead":"d7e9611ce126f9ea4282459bc85be1fa0c18ee2a","_id":"it-to-stream@0.1.2","_nodeVersion":"14.4.0","_npmVersion":"6.14.5","dist":{"integrity":"sha512-DTB5TJRZG3untmZehcaFN0kGWl2bNv7tnJRgQHAO9QEt8jfvVRrebZtnD5NZd4SCj4WVPjl0LSrugNWE/UaZRQ==","shasum":"7163151f75b60445e86b8ab1a968666acaacfe7b","tarball":"https://registry.npmjs.org/it-to-stream/-/it-to-stream-0.1.2.tgz","fileCount":13,"unpackedSize":16726,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJe/jszCRA9TVsSAnZWagAAAXUP/R+do/sUm4D0wMJYeJUH\na9fdShB/pegp/rqKnh+IJj6tZVX2fawNM7lnVyRRV6v0ue8fH+v6UxO5DrgL\nv5kih9q/b6qly4ZWWShFCdKqXITT6BKRKOY+14Ff4jNODK44CzBmAzLXS50s\nDZbrdCjhPnMqwqoErD+dpGq4n4z7WbjH9UIzMMF6PZJMLhrgV2R+IjacGswb\nLR22CXoB3VtFmmBeByZXRX1pXJuIF4O/Xe449tmBuIK4Ltyn/9KheG2DxDmr\n8rvwks78cDPZfeXA9AWxkbXDi4748fBRQsVGxqQFZXbL7b97zyTeAnbvPljd\nHTYPRn8mHz81/gELprnoCnUQKZJPZ99tZvcCsb3GJVBre2JBksQ6QBXM9YvC\nkQTnKkng6o0ct6KFDRRpg+UhOgy4Ul2D/imHPC1e5lVk7/7ezf0NlLuX7+2T\nD2LurIVfFlstRseB0gHVCyEB0TxZJFEfntvNFK6rsCtG5z3iupwRYbGDMnz3\nszqwJDLn5y3DsEcKp6tZH+ourb74cUsdpN23MAe0hgn36bcjR1949p1HGkAZ\ncD/s5thJdrFqwMWWiRLQHgv//l6WyVTIGIn1/kmylISd+kXUFFaHKqEBYcEP\ngGv70TF8wl5Fx/oYx2JhqfdbA6EUS++sDTmFnNNssk5T8qt+32Q99MYySX1x\nnAOP\r\n=eaY6\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHF5uP8FdOQV46OBF9K1Er0DwgqLJvx+ZesjCaalBbFCAiEAloAlVMyiTndzM7PhT6rhCv/LCQxkl/MRp0Xk0XN3+Is="}]},"maintainers":[{"name":"alanshaw","email":"alan138@gmail.com"}],"_npmUser":{"name":"alanshaw","email":"alan138@gmail.com"},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/it-to-stream_0.1.2_1593719603319_0.9642184834573542"},"_hasShrinkwrap":false},"1.0.0":{"name":"it-to-stream","version":"1.0.0","description":"Convert streaming iterables to Node.js streams","main":"src/index.js","browser":{"stream":"readable-stream"},"scripts":{"test":"ava test/*.test.js --verbose","lint":"standard","coverage":"nyc --reporter=text --reporter=lcov npm test"},"keywords":["stream","readablestream"],"author":{"name":"Alan Shaw"},"license":"MIT","dependencies":{"buffer":"^6.0.3","fast-fifo":"^1.0.0","get-iterator":"^1.0.2","p-defer":"^3.0.0","p-fifo":"^1.0.0","readable-stream":"^3.6.0"},"devDependencies":{"ava":"^3.9.0","it-pair":"^1.0.0","nyc":"^15.1.0","standard":"^16.0.3"},"directories":{"test":"test"},"repository":{"type":"git","url":"git+https://github.com/alanshaw/it-to-stream.git"},"bugs":{"url":"https://github.com/alanshaw/it-to-stream/issues"},"homepage":"https://github.com/alanshaw/it-to-stream#readme","gitHead":"082f0ad069d35f7f8608e905beffd6ac9176806c","_id":"it-to-stream@1.0.0","_nodeVersion":"15.12.0","_npmVersion":"7.6.3","dist":{"integrity":"sha512-pLULMZMAB/+vbdvbZtebC0nWBTbG581lk6w8P7DfIIIKUfa8FbY7Oi0FxZcFPbxvISs7A9E+cMpLDBc1XhpAOA==","shasum":"6c47f91d5b5df28bda9334c52782ef8e97fe3a4a","tarball":"https://registry.npmjs.org/it-to-stream/-/it-to-stream-1.0.0.tgz","fileCount":13,"unpackedSize":16894,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgbrr9CRA9TVsSAnZWagAAeq4P/17lDEeStkBRffropJZv\nT0Sb4oZrjRJc1yH/uCj3u4m/pLbLcTlsmSUn/XCGrJrkMaTPMJtOstDAbsqj\ndebXZmXTkg3TGvaxhZTbKb3UCJdcbQ3YDM0oB/eaPCvaVn78Xz1QxyxgWpNH\ntjSZV1mxyACqEbTM5dU8MbqjGdmYkQrCKtCtFy1PKQHJPT6F02mylGSaKAmL\nq3/6j3yysZk6wamjtwqZBGLqbZ/VGqq2FkovtDk9YIIbYuLt2p2CHYprfjDP\nO26YW3FZLo7Y5v2AI2IHCFWi7i8J94T/pjzEAu4DNmneANccOVyq01nyNmH8\ny8VMQ5X9sgc6mfpCBKYH1nWpiLnoS6sDBAEQSDl6TleF5a2h26GQbvdj+6US\nxQitm74sWuhsi8GXBEO/JLGVon07u69FY97adXPqu7qLFZkRUcvYdR198xVf\nBKwU0E8lrf2wDyjtpbM+Yq/SSz4FJJh7zF7wLmP5q3uXcLI+w9rZ3UsgHSKg\nGYFTWif7gZSvjP8R3PILiyWwLSUDwvssOlAI21NxcqyxkGZHbmB/5xkW9FVn\nj2qI3BtL2csLLAQxpYGh+u7xwBubFbWuEVG8F9hkJTqPJKg0zcjG2NuNtzfJ\nZPd0ACJFgeScpnico2rb6o5ojdv8W2vRWM5iEw+mhUpfYB2pvwH5hxgXARYw\n1BJw\r\n=l3dT\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEdeac7O93ny+BV8zFYC1IVZn6N47EzJixrPJ271FPdcAiBhl7QJbnW7bO5+jqbtvS761XAaC43fFWnh2gwaugubHg=="}]},"_npmUser":{"name":"alanshaw","email":"alan138@gmail.com"},"maintainers":[{"name":"alanshaw","email":"alan138@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/it-to-stream_1.0.0_1617869564701_0.19280600201734854"},"_hasShrinkwrap":false}},"time":{"created":"2019-07-31T14:20:42.415Z","0.1.0":"2019-07-31T14:20:42.556Z","modified":"2022-05-06T06:45:57.261Z","0.1.1":"2019-07-31T17:06:45.859Z","0.1.2":"2020-07-02T19:53:23.504Z","1.0.0":"2021-04-08T08:12:44.872Z"},"maintainers":[{"name":"alanshaw","email":"alan138@gmail.com"}],"description":"Convert streaming iterables to Node.js streams","homepage":"https://github.com/alanshaw/it-to-stream#readme","keywords":["stream","readablestream"],"repository":{"type":"git","url":"git+https://github.com/alanshaw/it-to-stream.git"},"author":{"name":"Alan Shaw"},"bugs":{"url":"https://github.com/alanshaw/it-to-stream/issues"},"license":"MIT","readme":"# it-to-stream\n\n[![Build Status](https://travis-ci.org/alanshaw/it-to-stream.svg?branch=master)](https://travis-ci.org/alanshaw/it-to-stream)\n[![dependencies Status](https://status.david-dm.org/gh/alanshaw/it-to-stream.svg)](https://david-dm.org/alanshaw/it-to-stream)\n[![JavaScript Style Guide](https://img.shields.io/badge/code_style-standard-brightgreen.svg)](https://standardjs.com)\n\n> Convert streaming iterables to Node.js streams\n\n## Install\n\n```sh\nnpm i it-to-stream\n```\n\n## Usage\n\n```js\nconst toStream = require('it-to-stream')\n```\n\n### Convert source iterable to readable stream\n\n```js\n// A streaming iterable \"source\" is just an (async) iterable\nconst source = (async function * () {\n  for (const value of [1, 2, 3, 4]) yield Buffer.from(value.toString())\n})()\n\nconst readable = toStream.readable(source)\n\n// Now we have a readable stream, we can consume it by\nreadable.on('data', console.log)\n// or\nreadable.pipe(writable)\n// or\npipeline(readable, writable, err => console.log(err || 'done'))\n```\n\n### Convert sink iterable to writable stream\n\n```js\n// A streaming iterable \"sink\" is an (async) function that takes a \"source\"\n// and consumes it.\nconst sink = async source => {\n  for await (const chunk of source) {\n    console.log(chunk.toString())\n  }\n}\n\nconst writable = toStream.writable(sink)\n\n// Now we have a writable stream, we can pipe to it\nfs.createReadStream('/path/to/file').pipe(writable)\n```\n\n### Convert transform iterable to transform stream\n\n```js\n// A streaming iterable \"transform\" is a function that takes a \"source\" and\n// returns a \"source\".\nconst transform = source => (async function * () {\n  for await (const chunk of source) {\n    // Replace all space characters with dashes\n    yield Buffer.from(chunk.toString().replace(/ /g, '-'))\n  }\n})()\n\nconst transform = toStream.transform(transform)\n\n// Now we have a transform stream, we can pipe to and from it\nfs.createReadStream('/path/to/file')\n  .pipe(transform)\n  .pipe(fs.createWriteStream('/path/to/file2'))\n```\n\n## API\n\n```js\nconst toStream = require('it-to-stream')\n```\n\n### `toStream.readable(source, [options]): Readable`\n\nConvert a [source](https://gist.github.com/alanshaw/591dc7dd54e4f99338a347ef568d6ee9#source-it) iterable to a [`Readable`](https://nodejs.org/dist/latest/docs/api/stream.html#stream_readable_streams) stream.\n\n`options` are passed directly to the `Readable` constructor.\n\n### `toStream.writable(sink, [options]): Writable`\n\nConvert a [sink](https://gist.github.com/alanshaw/591dc7dd54e4f99338a347ef568d6ee9#sink-it) iterable to a [`Writable`](https://nodejs.org/dist/latest/docs/api/stream.html#stream_writable_streams) stream.\n\n`options` are passed directly to the `Writable` constructor.\n\n### `toStream.transform(transform, [options]): Transform`\n\nConvert a [transform](https://gist.github.com/alanshaw/591dc7dd54e4f99338a347ef568d6ee9#transform-it) iterable to a [`Transform`](https://nodejs.org/dist/latest/docs/api/stream.html#stream_duplex_and_transform_streams) stream.\n\n`options` are passed directly to the `Transform` constructor.\n\n### `toStream.duplex(duplex, [options]): Duplex`\n\nConvert a [duplex](https://gist.github.com/alanshaw/591dc7dd54e4f99338a347ef568d6ee9#duplex-it) iterable to a [`Duplex`](https://nodejs.org/dist/latest/docs/api/stream.html#stream_duplex_and_transform_streams) stream.\n\n`options` are passed directly to the `Duplex` constructor.\n\n## Related\n\n* [`stream-to-it`](https://www.npmjs.com/package/stream-to-it) Convert Node.js streams to streaming iterables\n* [`it-pipe`](https://www.npmjs.com/package/it-pipe) Utility to \"pipe\" async iterables together\n\n## Contribute\n\nFeel free to dive in! [Open an issue](https://github.com/alanshaw/it-to-stream/issues/new) or submit PRs.\n\n## License\n\n[MIT](LICENSE) © Alan Shaw\n","readmeFilename":"README.md"}