{"_id":"@bensjoberg/rxjs-async-map","_rev":"1-7989d7a99b75c5aa14d06291fdcc1958","name":"@bensjoberg/rxjs-async-map","dist-tags":{"latest":"0.3.0"},"versions":{"0.3.0":{"name":"@bensjoberg/rxjs-async-map","version":"0.3.0","description":"Map an observable using an async function with a configurable concurreny level, while preserving element order.","main":"out/index.js","typings":"out/index.d.ts","scripts":{"lint":"tslint -p tsconfig.json","compile":"tsc","test":"jest --no-watchman"},"author":{"name":"Sam Rijs"},"license":"MIT","repository":{"type":"git","url":"git+https://github.com/srijs/rxjs-async-map.git"},"dependencies":{"rxjs":"^7.0.0"},"devDependencies":{"@types/jest":"^22.1.1","jasmine-promise-tools":"^1.1.0","jest":"^22.2.1","ts-jest":"^22.0.3","tslint":"^5.9.1","typescript":"^4.3.4"},"greenkeeper":{"ignore":["@types/jest","jest","ts-jest"]},"jest":{"collectCoverage":true,"coverageThreshold":{"global":{"branches":100,"functions":100,"lines":100,"statements":100}},"transform":{".ts":"<rootDir>/node_modules/ts-jest/preprocessor.js"},"testRegex":"src/.*\\.spec\\.ts$","moduleFileExtensions":["js","ts"]},"gitHead":"597646020082160b00e4302fbef4fa875777e584","bugs":{"url":"https://github.com/srijs/rxjs-async-map/issues"},"homepage":"https://github.com/srijs/rxjs-async-map#readme","_id":"@bensjoberg/rxjs-async-map@0.3.0","_nodeVersion":"16.8.0","_npmVersion":"7.21.1","dist":{"integrity":"sha512-4Jy6hIHXLPGDokWwDFEFrbyAKdirwJ9pgEx5M38fJZFWftVvkE4GN8jxRecFX//hI91IbAGHjiUvkwo65Lt1gQ==","shasum":"eb94392e562d78bc89fbf217f0556e1253c3fe8a","tarball":"https://registry.npmjs.org/@bensjoberg/rxjs-async-map/-/rxjs-async-map-0.3.0.tgz","fileCount":23,"unpackedSize":141260,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJhLldkCRA9TVsSAnZWagAAQvIP/RdhXiCjgqJBKq0S8U85\nqqHSAyMVvBVxKxKeiqluw/Qn+/+jMrVKDbFM75+IGSjHrs26KGANchxSEzHQ\nPeJLjr4AkxnC5PHJ/Xtdcksgcc9NmpCPEArpV0JQ3xVDbJ9S+belJL9l++KR\nM3Ysdfbw300LoMXOHbaSUCadzip1UnNwT/+VoZue4sqGQeq5+tShwRHCy2gK\nWC2CfWJ8oFVcCjTtfQZv8EpxliUrnrSycPy4lkmu0yVObkYGCTI4IbCmcerE\nugWVm8H3DeC8MVBotxZU8Ix21h4644vyIKW+wkQm36uIPY6g9wgmoWgxmuWo\nlVb8Ns52LBH4OlApSNUmmLQt7DdOg8xhcQZ9ila3rsOCKyEpcEwf4Y5qwHU2\neKneeMl4fhUs+3b13CD0qxQujEZ7TObTQYsQHj7P5Z9pZ7Fin+gMWaJlvMwX\n10cHLj5sEK7lNQVf4Uhgrgky6IOAA7yAWMoSWk+b9eakfM0w48zBYVdfqnb5\nraon9M+GrCyq1aJhJpuQrgQBo9EL9sJ2cmNseE+vM1wdbwT3bwh3XHuwVUVU\nhoDxKWmsPhO2lmlb6HSf/H254dyC3ZdfET2MqACIfKGOwFmGOi8DAZr5xE+w\n1CQNxA7na3uZ8VxBcYTvY2JBX5rlkNN2rUnJGMffrbKqmHE2pk/yko89J30M\nbxQ8\r\n=Rf7O\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDgGwLP6Bs2PKtR0yvJVx0zCiFQH36JgWSjwvdvezOc3gIhAJzuxIfJBdk0w+FRvqksjtuWKOheKV3sUFw/NNGIQZrr"}]},"_npmUser":{"name":"bensjoberg","email":"bensjoberg@gmail.com"},"directories":{},"maintainers":[{"name":"bensjoberg","email":"bensjoberg@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rxjs-async-map_0.3.0_1630426980501_0.8406202588297682"},"_hasShrinkwrap":false}},"time":{"created":"2021-08-31T16:23:00.454Z","0.3.0":"2021-08-31T16:23:00.648Z","modified":"2022-04-04T18:23:54.697Z"},"maintainers":[{"name":"bensjoberg","email":"bensjoberg@gmail.com"}],"description":"Map an observable using an async function with a configurable concurreny level, while preserving element order.","homepage":"https://github.com/srijs/rxjs-async-map#readme","repository":{"type":"git","url":"git+https://github.com/srijs/rxjs-async-map.git"},"author":{"name":"Sam Rijs"},"bugs":{"url":"https://github.com/srijs/rxjs-async-map/issues"},"license":"MIT","readme":"# rxjs-async-map\n\nMap an observable using an async function with a configurable concurreny level, while preserving element order.\n\n[![CircleCI](https://img.shields.io/circleci/project/github/srijs/rxjs-async-map.svg)](https://circleci.com/gh/srijs/rxjs-async-map/tree/master)\n[![Greenkeeper badge](https://badges.greenkeeper.io/srijs/rxjs-async-map.svg)](https://greenkeeper.io/)\n\n## Installation\n\n`rxjs-async-map` is available via npm or yarn:\n\n```\nnpm i --save rxjs-async-map\n```\n\n```\nyarn add rxjs-async-map\n```\n\n## Usage\n\n```js\nimport { of } from 'rxjs/observable/of';\nimport { asyncMap } from 'rxjs-async-map';\n\nconst myPromise = val =>\n  new Promise(resolve => setTimeout(() => resolve(`Result: ${val}`), Math.random() * 1000));\n\nconst source = of(1, 2, 3);\n\n// Map over the observable using the async function, while running\n// up to two promises concurrently.\n//\n// The order of elements is preserved, even if the promises resolve\n// out-of-order.\nconst example = source.pipe(asyncMap(myPromise, /* concurrency: */ 2));\n\n/*\n  output:\n  \"Result: 1\"\n  \"Result: 2\"\n  \"Result: 3\"\n*/\nconst subscribe = example.subscribe(val => console.log(val));\n```\n\n## License\n\nMIT\n","readmeFilename":"README.md"}