{"_id":"pipeline-pipe","_rev":"273837","name":"pipeline-pipe","description":"Creates a parallel transform from async function","dist-tags":{"latest":"0.3.0"},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"time":{"modified":"2021-06-03T17:52:46.000Z","created":"2019-10-22T11:49:03.332Z","0.3.0":"2021-03-22T00:50:22.005Z","0.2.2":"2021-03-21T01:42:44.527Z","0.2.1":"2021-03-20T15:53:50.075Z","0.2.0":"2021-03-20T05:01:11.576Z","0.1.5":"2021-01-27T14:56:57.782Z","0.1.4":"2019-12-31T04:40:33.211Z","0.1.3":"2019-10-26T14:15:38.430Z","0.1.1":"2019-10-22T12:57:20.208Z","0.1.0":"2019-10-22T11:49:03.332Z"},"users":{},"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"repository":{"type":"git","url":"https://github.com/piglovesyou/pipeline-pipe.git"},"versions":{"0.3.0":{"name":"pipeline-pipe","version":"0.3.0","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"https://github.com/piglovesyou/pipeline-pipe.git"},"bugs":{"url":"https://github.com/piglovesyou/pipeline-pipe/issues"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","readable-stream":"^3.6.0"},"devDependencies":{"@types/eslint":"^7.2.7","@types/eslint-plugin-prettier":"^3.1.0","@types/jest":"^26.0.21","@types/node":"^14.14.35","@types/readable-stream":"^2.3.9","@typescript-eslint/eslint-plugin":"^4.18.0","@typescript-eslint/parser":"^4.18.0","eslint":"^7.22.0","eslint-config-prettier":"^8.1.0","eslint-plugin-jest":"^24.3.2","eslint-plugin-prettier":"^3.3.1","jest":"^26.6.3","prettier":"^2.2.1","ts-jest":"^26.5.4","typescript":"^4.2.3"},"lint-staged":{"*.{ts,js}":["yarn _eslint --fix","git add --force"]},"scripts":{"_eslint":"eslint --ext .ts --ignore-path .gitignore","lint":"yarn _eslint .","fix":"yarn _eslint --fix .","test-watch":"yarn test --watch --notify","test-cover":"yarn test --coverage","test":"yarn lint && tsc --noEmit && jest","test-nolint":"tsc --noEmit && jest","build":"tsc --declaration","prepack":"yarn lint && yarn build && yarn test"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"licenseText":"Copyright 2013 Mathias Buus\n\nPermission is hereby granted, free of charge, to any person obtaining\na copy of this software and associated documentation files (the\n\"Software\"), to deal in the Software without restriction, including\nwithout limitation the rights to use, copy, modify, merge, publish,\ndistribute, sublicense, and/or sell copies of the Software, and to\npermit persons to whom the Software is furnished to do so, subject to\nthe following conditions:\n\nThe above copyright notice and this permission notice shall be\nincluded in all copies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\nEXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\nMERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\nNONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE\nLIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION\nOF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION\nWITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\n","_id":"pipeline-pipe@0.3.0","dist":{"shasum":"7d29dd49f4a09a63bdfa0e74b723bfb202eb632e","size":6465,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.3.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.3.0.tgz"},"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.3.0_1616374221850_0.42017526002329"},"_hasShrinkwrap":false,"publish_time":1616374222005,"_cnpm_publish_time":1616374222005},"0.2.2":{"name":"pipeline-pipe","version":"0.2.2","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git@github.com:piglovesyou/pipeline-pipe.git"},"homepage":"https://github.com/piglovesyou/pipeline-pipe","license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","readable-stream":"^3.6.0"},"devDependencies":{"@types/eslint":"^7.2.7","@types/eslint-plugin-prettier":"^3.1.0","@types/jest":"^26.0.21","@types/node":"^14.14.35","@types/readable-stream":"^2.3.9","@typescript-eslint/eslint-plugin":"^4.18.0","@typescript-eslint/parser":"^4.18.0","eslint":"^7.22.0","eslint-config-prettier":"^8.1.0","eslint-plugin-jest":"^24.3.2","eslint-plugin-prettier":"^3.3.1","jest":"^26.6.3","prettier":"^2.2.1","ts-jest":"^26.5.4","typescript":"^4.2.3"},"lint-staged":{"*.{ts,js}":["yarn _eslint --fix","git add --force"]},"scripts":{"_eslint":"eslint --ext .ts --ignore-path .gitignore","lint":"yarn _eslint .","fix":"yarn _eslint --fix .","test-watch":"yarn test --watch --notify","test-cover":"yarn test --coverage","test":"yarn lint && tsc --noEmit && jest","test-nolint":"tsc --noEmit && jest","build":"tsc --declaration","prepack":"yarn lint && yarn build && yarn test"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"licenseText":"Copyright 2013 Mathias Buus\n\nPermission is hereby granted, free of charge, to any person obtaining\na copy of this software and associated documentation files (the\n\"Software\"), to deal in the Software without restriction, including\nwithout limitation the rights to use, copy, modify, merge, publish,\ndistribute, sublicense, and/or sell copies of the Software, and to\npermit persons to whom the Software is furnished to do so, subject to\nthe following conditions:\n\nThe above copyright notice and this permission notice shall be\nincluded in all copies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\nEXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\nMERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\nNONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE\nLIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION\nOF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION\nWITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\n","_id":"pipeline-pipe@0.2.2","dist":{"shasum":"25a8306d91a151ccd5d6e4a253d496a246757773","size":6465,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.2.2.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.2.2.tgz"},"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.2.2_1616290964391_0.8770207025640524"},"_hasShrinkwrap":false,"publish_time":1616290964527,"_cnpm_publish_time":1616290964527},"0.2.1":{"name":"pipeline-pipe","version":"0.2.1","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git@github.com:piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","readable-stream":"^3.6.0"},"devDependencies":{"@types/eslint":"^7.2.7","@types/eslint-plugin-prettier":"^3.1.0","@types/jest":"^26.0.21","@types/node":"^14.14.35","@types/readable-stream":"^2.3.9","@typescript-eslint/eslint-plugin":"^4.18.0","@typescript-eslint/parser":"^4.18.0","eslint":"^7.22.0","eslint-config-prettier":"^8.1.0","eslint-plugin-jest":"^24.3.2","eslint-plugin-prettier":"^3.3.1","jest":"^26.6.3","prettier":"^2.2.1","ts-jest":"^26.5.4","typescript":"^4.2.3"},"lint-staged":{"*.{ts,js}":["yarn _eslint --fix","git add --force"]},"scripts":{"_eslint":"eslint --ext .ts --ignore-path .gitignore","lint":"yarn _eslint .","fix":"yarn _eslint --fix .","test-watch":"yarn test --watch --notify","test-cover":"yarn test --coverage","test":"yarn lint && tsc --noEmit && jest","test-nolint":"tsc --noEmit && jest","build":"tsc --declaration","prepack":"yarn lint && yarn build && yarn test"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"licenseText":"Copyright 2013 Mathias Buus\n\nPermission is hereby granted, free of charge, to any person obtaining\na copy of this software and associated documentation files (the\n\"Software\"), to deal in the Software without restriction, including\nwithout limitation the rights to use, copy, modify, merge, publish,\ndistribute, sublicense, and/or sell copies of the Software, and to\npermit persons to whom the Software is furnished to do so, subject to\nthe following conditions:\n\nThe above copyright notice and this permission notice shall be\nincluded in all copies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\nEXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\nMERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\nNONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE\nLIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION\nOF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION\nWITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\n","_id":"pipeline-pipe@0.2.1","dist":{"shasum":"f767dc2140993060480e7c4bf006110253d6fe7b","size":6459,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.2.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.2.1.tgz"},"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.2.1_1616255629929_0.6799270220184914"},"_hasShrinkwrap":false,"publish_time":1616255630075,"_cnpm_publish_time":1616255630075},"0.2.0":{"name":"pipeline-pipe","version":"0.2.0","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git@github.com:piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","readable-stream":"^3.6.0"},"devDependencies":{"@types/eslint":"^7.2.6","@types/eslint-plugin-prettier":"^3.1.0","@types/jest":"^26.0.20","@types/node":"^14.14.22","@types/readable-stream":"^2.3.9","@typescript-eslint/eslint-plugin":"^4.14.1","@typescript-eslint/parser":"^4.14.1","eslint":"^7.18.0","eslint-config-prettier":"^8.1.0","eslint-plugin-jest":"^24.1.3","eslint-plugin-prettier":"^3.3.1","jest":"^26.6.3","prettier":"^2.2.1","ts-jest":"^26.4.4","typescript":"^4.1.3"},"lint-staged":{"*.{ts,tsx}":["npm run fix-js","git add --force"]},"scripts":{"lint":"eslint --ext .ts --ignore-path .gitignore --ignore-pattern \"**/*.test.ts\" .","fix":"yarn run lint --fix","test-watch":"yarn run test --watch --notify","test-cover":"yarn run test --coverage","test":"yarn lint && tsc --noEmit && jest","test-nolint":"tsc --noEmit && jest","prepack":"tsc --declaration"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"licenseText":"Copyright 2013 Mathias Buus\n\nPermission is hereby granted, free of charge, to any person obtaining\na copy of this software and associated documentation files (the\n\"Software\"), to deal in the Software without restriction, including\nwithout limitation the rights to use, copy, modify, merge, publish,\ndistribute, sublicense, and/or sell copies of the Software, and to\npermit persons to whom the Software is furnished to do so, subject to\nthe following conditions:\n\nThe above copyright notice and this permission notice shall be\nincluded in all copies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\nEXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\nMERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\nNONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE\nLIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION\nOF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION\nWITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\n","_id":"pipeline-pipe@0.2.0","dist":{"shasum":"2e58a13ef9a431dd690cac4f40df1563a1536f22","size":5696,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.2.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.2.0.tgz"},"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.2.0_1616216471417_0.7005144268549"},"_hasShrinkwrap":false,"publish_time":1616216471576,"_cnpm_publish_time":1616216471576},"0.1.5":{"name":"pipeline-pipe","version":"0.1.5","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git@github.com:piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","readable-stream":"^3.6.0"},"devDependencies":{"@types/eslint":"^7.2.6","@types/eslint-plugin-prettier":"^3.1.0","@types/jest":"^26.0.20","@types/node":"^14.14.22","@types/readable-stream":"^2.3.9","@typescript-eslint/eslint-plugin":"^4.14.1","@typescript-eslint/parser":"^4.14.1","eslint":"^7.18.0","eslint-config-prettier":"^7.2.0","eslint-plugin-jest":"^24.1.3","eslint-plugin-prettier":"^3.3.1","jest":"^26.6.3","prettier":"^2.2.1","ts-jest":"^26.4.4","typescript":"^4.1.3"},"lint-staged":{"*.{ts,tsx}":["npm run fix-js","git add --force"]},"scripts":{"lint":"eslint --ext .ts --ignore-path .gitignore --ignore-pattern \"**/*.test.ts\" .","fix":"yarn run lint --fix","test-watch":"yarn run test --watch --notify","test-cover":"yarn run test --coverage","test":"yarn lint && tsc --noEmit && jest","prepack":"tsc --declaration"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"licenseText":"Copyright 2013 Mathias Buus\n\nPermission is hereby granted, free of charge, to any person obtaining\na copy of this software and associated documentation files (the\n\"Software\"), to deal in the Software without restriction, including\nwithout limitation the rights to use, copy, modify, merge, publish,\ndistribute, sublicense, and/or sell copies of the Software, and to\npermit persons to whom the Software is furnished to do so, subject to\nthe following conditions:\n\nThe above copyright notice and this permission notice shall be\nincluded in all copies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND,\nEXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\nMERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\nNONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE\nLIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION\nOF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION\nWITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\n","_id":"pipeline-pipe@0.1.5","dist":{"shasum":"01c4b4336a35d483a21f31f7e3a9c4cc5022f06c","size":6248,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.1.5.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.1.5.tgz"},"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.1.5_1611759417569_0.1520726739546061"},"_hasShrinkwrap":false,"publish_time":1611759417782,"_cnpm_publish_time":1611759417782},"0.1.4":{"name":"pipeline-pipe","version":"0.1.4","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git+ssh://git@github.com/piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","readable-stream":"^3.4.0"},"devDependencies":{"@types/eslint":"^6.1.3","@types/eslint-plugin-prettier":"^2.2.0","@types/jest":"^24.0.19","@types/node":"^13.1.2","@types/readable-stream":"^2.3.5","@typescript-eslint/eslint-plugin":"^2.14.0","@typescript-eslint/parser":"^2.14.0","eslint":"^6.8.0","eslint-config-prettier":"^6.4.0","eslint-plugin-jest":"^23.2.0","eslint-plugin-prettier":"^3.1.1","jest":"^24.9.0","prettier":"^1.19.1","ts-jest":"^24.1.0","typescript":"^3.7.4"},"lint-staged":{"*.{ts,tsx}":["npm run fix-js","git add --force"]},"scripts":{"lint":"eslint --ext .ts --ignore-path .gitignore --ignore-pattern \"**/*.test.ts\" .","fix":"yarn run lint --fix","test-watch":"yarn run test --watch --notify","test-cover":"yarn run test --coverage","test":"yarn lint && tsc --noEmit && jest","prepack":"tsc --declaration"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"gitHead":"b9dfe514b2655d3f5a13c99a109ed503d54892f9","bugs":{"url":"https://github.com/piglovesyou/pipeline-pipe/issues"},"homepage":"https://github.com/piglovesyou/pipeline-pipe#readme","_id":"pipeline-pipe@0.1.4","_nodeVersion":"13.3.0","_npmVersion":"6.13.4","dist":{"shasum":"d6ddcf3c45d6d4547793b775f9b87f605334a984","size":6040,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.1.4.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.1.4.tgz"},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.1.4_1577767233009_0.4332908182253776"},"_hasShrinkwrap":false,"publish_time":1577767233211,"_cnpm_publish_time":1577767233211},"0.1.3":{"name":"pipeline-pipe","version":"0.1.3","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git+ssh://git@github.com/piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","eslint-plugin-import":"^2.18.2","readable-stream":"^3.4.0"},"devDependencies":{"@types/jest":"^24.0.19","@types/node":"^12.11.1","@types/readable-stream":"^2.3.5","@typescript-eslint/eslint-plugin":"^2.5.0","@typescript-eslint/parser":"^2.5.0","eslint":"^6.5.1","eslint-config-airbnb":"^18.0.1","eslint-config-prettier":"^6.4.0","eslint-plugin-jsx-a11y":"^6.2.3","eslint-plugin-node":"^10.0.0","eslint-plugin-prettier":"^3.1.1","jest":"^24.9.0","ts-jest":"^24.1.0","ts-node":"^8.4.1","typescript":"^3.6.4"},"lint-staged":{"*.{ts,tsx}":["npm run fix-js","git add --force"]},"scripts":{"lint":"eslint --ext .ts --ignore-path .gitignore --ignore-pattern \"**/*.test.ts\" .","fix":"yarn run lint --fix","test-watch":"yarn run test --watch --notify","test-cover":"yarn run test --coverage","test":"yarn lint && tsc --noEmit && jest","prepack":"tsc --declaration"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"gitHead":"83d13e57211510b1cf270f203f945406ac2ff704","bugs":{"url":"https://github.com/piglovesyou/pipeline-pipe/issues"},"homepage":"https://github.com/piglovesyou/pipeline-pipe#readme","_id":"pipeline-pipe@0.1.3","_nodeVersion":"10.17.0","_npmVersion":"6.11.3","dist":{"shasum":"1d06bddb9fc1be33b2073a44a1760f281498eaaf","size":73229,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.1.3.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.1.3.tgz"},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.1.3_1572099338233_0.21071821366726184"},"_hasShrinkwrap":false,"publish_time":1572099338430,"_cnpm_publish_time":1572099338430},"0.1.1":{"name":"pipeline-pipe","version":"0.1.1","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git+ssh://git@github.com/piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","eslint-plugin-import":"^2.18.2","readable-stream":"^3.4.0"},"devDependencies":{"@types/jest":"^24.0.19","@types/node":"^12.11.1","@types/readable-stream":"^2.3.5","@typescript-eslint/eslint-plugin":"^2.5.0","@typescript-eslint/parser":"^2.5.0","eslint":"^6.5.1","eslint-config-airbnb":"^18.0.1","eslint-config-prettier":"^6.4.0","eslint-plugin-jsx-a11y":"^6.2.3","eslint-plugin-node":"^10.0.0","eslint-plugin-prettier":"^3.1.1","jest":"^24.9.0","ts-jest":"^24.1.0","ts-node":"^8.4.1","typescript":"^3.6.4"},"lint-staged":{"*.{ts,tsx}":["npm run fix-js","git add --force"]},"scripts":{"lint":"eslint --ext .ts --ignore-path .gitignore --ignore-pattern \"**/*.test.ts\" .","fix":"yarn run lint --fix","test-watch":"yarn run test --watch --notify","test-cover":"yarn run test --coverage","test":"yarn lint && tsc --noEmit && jest","prepack":"tsc --declaration"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"gitHead":"830063e0e3286b5948f4a2d9542e4e0ae3d736fa","bugs":{"url":"https://github.com/piglovesyou/pipeline-pipe/issues"},"homepage":"https://github.com/piglovesyou/pipeline-pipe#readme","_id":"pipeline-pipe@0.1.1","_nodeVersion":"12.10.0","_npmVersion":"6.12.0","dist":{"shasum":"1cb490deddafb5a7a1a3d328c4dd366980ee083c","size":72619,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.1.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.1.1.tgz"},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.1.1_1571749040058_0.693627439314594"},"_hasShrinkwrap":false,"publish_time":1571749040208,"_cnpm_publish_time":1571749040208},"0.1.0":{"name":"pipeline-pipe","version":"0.1.0","engines":{"node":">=10.0.0"},"main":"dist/index.js","types":"dist/index.d.ts","repository":{"type":"git","url":"git+ssh://git@github.com/piglovesyou/pipeline-pipe.git"},"license":"MIT","description":"Creates a parallel transform from async function","keywords":["transform","stream","parallel"],"author":{"name":"Soichi Takamura","email":"thepiglovesyou@gmail.com"},"dependencies":{"cyclist":"^1.0.1","eslint-plugin-import":"^2.18.2","readable-stream":"^3.4.0"},"devDependencies":{"@types/jest":"^24.0.19","@types/node":"^12.11.1","@types/readable-stream":"^2.3.5","@typescript-eslint/eslint-plugin":"^2.5.0","@typescript-eslint/parser":"^2.5.0","eslint":"^6.5.1","eslint-config-airbnb":"^18.0.1","eslint-config-prettier":"^6.4.0","eslint-plugin-jsx-a11y":"^6.2.3","eslint-plugin-node":"^10.0.0","eslint-plugin-prettier":"^3.1.1","jest":"^24.9.0","ts-jest":"^24.1.0","ts-node":"^8.4.1","typescript":"^3.6.4"},"lint-staged":{"*.{ts,tsx}":["npm run fix-js","git add --force"]},"scripts":{"lint":"eslint --ext .ts --ignore-path .gitignore --ignore-pattern \"**/*.test.ts\" .","fix":"yarn run lint --fix","test-watch":"yarn run test --watch --notify","test-cover":"yarn run test --coverage","test":"yarn lint && tsc --noEmit && jest","prepack":"tsc --declaration"},"husky":{"hooks":{"pre-commit":"lint-staged"}},"gitHead":"d87269e0b46a4b2a168c3b2cd52a6d335e1f04eb","bugs":{"url":"https://github.com/piglovesyou/pipeline-pipe/issues"},"homepage":"https://github.com/piglovesyou/pipeline-pipe#readme","_id":"pipeline-pipe@0.1.0","_nodeVersion":"12.10.0","_npmVersion":"6.12.0","dist":{"shasum":"b187233c2b3da3ac1a498065489742b964d8e26f","size":72620,"noattachment":false,"key":"/pipeline-pipe/-/pipeline-pipe-0.1.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/pipeline-pipe/download/pipeline-pipe-0.1.0.tgz"},"maintainers":[{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"}],"_npmUser":{"name":"piglovesyou","email":"thepiglovesyou@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipeline-pipe_0.1.0_1571744943190_0.23216377655127407"},"_hasShrinkwrap":false,"publish_time":1571744943332,"_cnpm_publish_time":1571744943332}},"readme":"# pipeline-pipe [![Node CI](https://github.com/piglovesyou/pipeline-pipe/actions/workflows/nodejs.yml/badge.svg)](https://github.com/piglovesyou/pipeline-pipe/actions/workflows/nodejs.yml) [![npm version](https://badge.fury.io/js/pipeline-pipe.svg)](https://badge.fury.io/js/pipeline-pipe) [![downloads](https://badgen.net/npm/dw/pipeline-pipe)](https://www.npmjs.com/package/pipeline-pipe)\n\nParallel transform and some utilities for Node Object Stream lovers\n\n## Why\n\n* Parallel transform accepting async function\n* Fixes [mafintosh/parallel-transform/issues/4](https://github.com/mafintosh/parallel-transform/issues/4) to work with [`import { pipeline } from 'stream'`](https://nodejs.org/api/stream.html#stream_stream_pipeline_source_transforms_destination_callback)\n* TypeScript Definition with the pure TypeScript reimplementation\n* Add tests\n* Utility functions\n* [Blog post](https://dev.to/piglovesyou/pipeline-pipe-fun-way-to-get-batching-done-with-node-stream-42cb)\n\n## Install\n\n```bash\nnpm install pipeline-pipe\n```\n\n## pipe(fn, opts)\n\nExample usage:\n\n```js\n// Example to scrape HTML and store titles of them in DB:\n\nconst { pipeline, Readable } = require('stream');\nconst pipe = require('pipeline-pipe');\n\npipeline(\n    Readable.from([1, 2, 3]),\n\n    // Request HTML asynchronously in 16 parallel\n    pipe(async postId => {\n      const json = await getPost(postId);\n      return json;\n    }, 16),\n\n    // Synchronous transformation as Array.prototype.map\n    pipe(json => parseHTML(json.postBody).document.title),\n\n    // Synchronous transformation as Array.prototype.filter\n    pipe(title => title.includes('important') ? title : null),\n\n    // Asynchronous in 4 parallel\n    pipe(async title => {\n      const result = await storeInDB(title), 4);\n      console.info(result);\n    }, 4)\n\n    (err) => console.info('All done!')\n);\n```\n\nTypes:\n\n```typescript\nimport { Transform, TransformOptions } from 'stream';\n\ntype ParallelTransformOpitons =\n  | number\n  | TransformOptions & { maxParallel?: number, ordered?: boolean };\n\nexport default function pipe(\n    fn: (data: any) => Promise<any> | any,\n    opts?: ParallelTransformOptions,\n): Transform;\n ```\n\n| Option property | Default value | description |\n| --- | --- | --- |\n| **`maxParallel`**  | `10` | Number of maximum parallel executions. |\n| **`ordered`**      | `true` | Preserving order of streaming chunks. |\n\nA number can be passed to `opts`. `pipe(fn, 20)` is same as `pipe(fn, {maxParallel: 20})`.\n\n## Some utility functions\n\n### pipeline(stream, stream, ...)\n\nA promisified version of `require('stream').pipeline`. Equivalent to:\n\n```js\nconst { promisify } = require('util');\nconst { pipeline: _pipeline } = require('stream');\nconst pipeline = promisify(_pipeline);\n```\n\nExample:\n\n```js\nconst { pipeline, pipe } = require('pipeline-pipe');\n\nawait pipeline(\n    readable,\n    pipe(chunk => chunk.replace('a', 'z')),\n    pipe(chunk => storeInDB(chunk)),\n);\nconsole.log('All done!');\n```\n\n### concat(size)\n\nIt concatenates sequential data to be specified size of array. This is useful when you post array data at once in the way that [Elasticsearch Bulk API does](https://www.elastic.co/guide/en/elasticsearch/reference/6.2/docs-bulk.html).\n\nExample:\n```javascript\nconst { pipeline } = require('stream');\nconst { concat, pipe } = require('pipeline-pipe');\n\npipeline(\n    Readable.from([1, 2, 3, 4, 5]),\n    concat(2),\n    pipe(console.log),  // [ 1, 2 ]\n                        // [ 3, 4 ]\n                        // [ 5 ]\n    (err) => console.info('All done!'),\n);\n```\n\n### split()\n\nCreates a `Transform` to split incoming `Array` chunk into pieces to subsequent streams.\n\n```js\nconst { pipeline } = require('stream');\nconst { split, pipe } = require('pipeline-pipe');\n\npipeline(\n    Readable.from([1, 2, 3]),\n    pipe(page => getPostsByPage(page)),\n    pipe(json => json.posts),               // Returns an array of posts\n    split(),                                // Splits the array into each posts\n    pipe(post => storeInDB(post.title)),    // Now the argument is a post\n    (err) => console.info('All done!')\n);\n```\n\n## License\n\nMIT\n","_attachments":{},"bugs":{"url":"https://github.com/piglovesyou/pipeline-pipe/issues"},"license":"MIT"}