{"_id":"@annexwu-packages/multiple-stream-utils","_rev":"1-33385f75bf62fcc8a63571cc590fb863","name":"@annexwu-packages/multiple-stream-utils","dist-tags":{"latest":"0.0.1"},"versions":{"0.0.1":{"name":"@annexwu-packages/multiple-stream-utils","version":"0.0.1","description":"this is a utils which contains several multiple stream functions","main":"index.js","author":{"name":"annexwu"},"license":"MIT","dependencies":{},"gitHead":"026ae4a684ccace1ace4a6636805ba5dcf2523dc","_id":"@annexwu-packages/multiple-stream-utils@0.0.1","_nodeVersion":"10.24.0","_npmVersion":"6.14.8","dist":{"integrity":"sha512-4Opq9ZHmKckgrVRHYeoA9Ccu32zNQnhAAiB07HIQGut5MrNvjl6CdtPcUG9uugD4rrRSmibuXZ5BXxCbz8Kxdg==","shasum":"12e2c2a61f9cb335ce77a747729e076c365bc5b3","tarball":"https://registry.npmjs.org/@annexwu-packages/multiple-stream-utils/-/multiple-stream-utils-0.0.1.tgz","fileCount":5,"unpackedSize":6910,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJg7UY3CRA9TVsSAnZWagAABxcP/jO1cVjS+madFE5mTz/3\nbEN89kEd1OBBbNhguXtd22E8fwzOKDqbDcD3/HznTuLyudjqAaU+wgpXsWqd\n9onzs81eSArYw1i7JVOvU+2DhlqXLr6vvq0spzGTKN7jCV78dhAqra+EnW9q\nqXVWqG9mB4Tk7w10WI0UkHnU1m1SA48qTGsRtrpMQlaWtIEJmd7y6h1MfjoL\n3aiLQKIkz/rRj/UxWofkOcgYYHgIXII6n4N6CkDRs/50KT/lLJ/PSAwaV0y9\nRFBG2oLggM9rdJZfdKQwYa1C+gvvHa15deVNU8ul7qg3P+gOPPmQf/S20Xtq\nC97uEjXJNGgaAgXEYfapFPkyMTwFea8dLPpJxElcy47pnmv56m8lBwiA7Ooj\nq+9M4HrR2TBRf1Yk4n2iEc+EOknvgPgyaQDn8WWiG++sB9A2RHy/KTnmORB+\nSgkCybhsl7sCPoSs5/Y8etQUT8jboQ298gQIiXaqqAuJhAc0w6yCic8wdvIH\nUZ8piZW65VuxXBlqkeTrmUvOjsEEU2z66iNlonkpS7jxe+EpCoXk3cUDLuli\nFsVIihFrJjtNI9XuNSmSZ79QaXRdUGj9ahSqlypDNweron+Cw3iB2DjJa51s\nJGfOsv7g9DBfWweUm7M7cKP3dHhOmyTiWG8MvssygsIDVO8OvF1i62YqqKtz\n4wqD\r\n=xWT0\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFADujFXCZRw97J3TS/3PG4HdQpOrhkVTRNuF4bUOiRUAiAXaylQ+4Ec5S4x//+QCdmjq+IC9rDgq4ZjyR4UU5jOCA=="}]},"_npmUser":{"name":"annexwu","email":"annexwu@tencent.com"},"directories":{},"maintainers":[{"name":"annexwu","email":"annexwu@tencent.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/multiple-stream-utils_0.0.1_1626162743241_0.7281731629723476"},"_hasShrinkwrap":false}},"time":{"created":"2021-07-13T07:52:22.837Z","0.0.1":"2021-07-13T07:52:23.360Z","modified":"2022-04-04T14:14:18.126Z"},"maintainers":[{"name":"annexwu","email":"annexwu@tencent.com"}],"description":"this is a utils which contains several multiple stream functions","author":{"name":"annexwu"},"license":"MIT","readme":"### @annexwu-packages/multiple-stream-utils\r\n\r\n## Usage\r\n\r\n```js\r\nconst { MultipleWriteStream } = require('@annexwu-packages/multiple-stream-utils');\r\n\r\nconst writeStream = new MultipleWriteStream({\r\n  nextStreamEvent: 'finish',\r\n  async getNextStream({ number = 0 } = {}) {\r\n    if(number >= 10) {\r\n      return;\r\n    }\r\n    return {\r\n      stream: fs.createWriteStream(`./${number}.md`),\r\n      streamSize: 1 * 1024 * 1024,\r\n      nextParams: {\r\n        number: number + 1,\r\n      },\r\n    }\r\n  },\r\n});\r\n\r\nreadStream.pipe(writeStream);\r\n```\r\n\r\n## API\r\n\r\n### MultipleWriteStream\r\n\r\nCreate a writable stream which combine by multiple writable stream\r\n\r\n```js\r\nconst { MultipleWriteStream } = require('@annexwu-packages/multiple-stream-utils');\r\n\r\nconst writeStream = new MultipleWriteStream({\r\n  nextStreamEvent: 'finish',\r\n  async getNextStream({ number = 0 } = {}) {\r\n    if(number >= 10) {\r\n      return;\r\n    }\r\n    return {\r\n      stream: fs.createWriteStream(`./${number}.md`),\r\n      streamSize: 1 * 1024 * 1024,\r\n      nextParams: {\r\n        number: number + 1,\r\n      },\r\n    }\r\n  },\r\n});\r\n\r\nreadStream.pipe(writeStream);\r\n```\r\n","readmeFilename":"README.md"}