{"_id":"92green-rxjs","_rev":"7-f5c248878f1d706457fa1f19766c90ea","name":"92green-rxjs","dist-tags":{"latest":"0.10.0"},"versions":{"0.7.0":{"name":"92green-rxjs","version":"0.7.0","description":"Rxjs algorithms","license":"MIT","author":{"name":"Blueflag"},"repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"main":"lib/index.js","scripts":{"prepublish":"yarn build","build":"rm -rf lib && NODE_ENV=production yarn babel src --out-dir lib --ignore '**/__tests__/*.js'","build-all":"yarn build","flow":"blueflag-test flow","flow-coverage":"blueflag-test flow-coverage","lint":"blueflag-test lint","test":"yarn build && yarn jest --maxWorkers=1","test-all":"yarn build && yarn jest --maxWorkers=1 && yarn flow && yarn lint && yarn flow-coverage","watch":"yarn run build -w"},"dependencies":{"@babel/runtime":"^7.1.5"},"devDependencies":{"@babel/cli":"^7.1.2","@babel/core":"^7.1.2","babel-preset-blueflag":"^1.0.0","blueflag-test":"^0.22.0","rxjs":"^6.5.2"},"peerDependencies":{"rxjs":"^6.5.2"},"gitHead":"6cf60b1db0c2bfd0989f727f4a2737616feab333","homepage":"https://github.com/92green/92green-stream#readme","_id":"92green-rxjs@0.7.0","_nodeVersion":"10.15.3","_npmVersion":"lerna/3.14.1/node@v10.15.3+x64 (darwin)","dist":{"integrity":"sha512-CfaGAlSxsiLt3iO0ewr5YxjQpto9evp+IUNxkd6icUlGFuWsBKeg0HtNH+7H5K46/OLvxRu0xq0V5i/zjLVZig==","shasum":"fd4d5cef1e676cec4c36815ec1131c1aca994550","tarball":"https://registry.npmjs.org/92green-rxjs/-/92green-rxjs-0.7.0.tgz","fileCount":15,"unpackedSize":25101,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJex0BgCRA9TVsSAnZWagAAp3oP/iXf2CCtU6v5pWefVHOY\nHO/sYTJnNoomcCuNay7vR94Idj6NgUmiVSFwi6lbd/s/XJCMVaINMqfy3gFh\n1UEJPGZI/3fUtgAUVO6TrWP1or5s/9LJjDmCtaMd1aWEwfiWG65+6Dz6J14r\n1i4b+q04eYjFRpsbYV+mGTpkeWW7YLj0PKCQtzFfFSppBtTVs21i0TQ7zou1\nOtLrAYEWA03sEQTfYLWpC34no5J3hsoGsM2KQNht8MlC5TUYYc8I3j7N/Uqf\nLLj43MyxMpHu3z6uqZwiK2gwTj6KSgmqQwpV83h3lD9qfJwS49/wegCwrEUy\noFYM81oG8RfYQMQ/HQFAZdPl07rindQQKZzL90AtYJplH9Y2y3CxKNO5OAaF\nwRoR1r/8BJ1gmLvXS8yKZZBjDHLqBRy3UmFhaAtNbKJ52CU5JH3zCiMZxdb6\nORReX/6OUUNnDVQ3Wp2AvQzOyCIAX7p7wUl+MLeKlvr8vx+eKKBTzP4MQCkw\nWXZG3CFBNRgz+zf7u2UmIBY/2g69GsyRtg5+ypsOZxmAmS53Osm7BQ9wQd85\nJ3ksXZaIXcEO20ggAwn8MS8CDfl0937HJT0O02B/yxwFmoP8OhK/t+oB76uz\noV49JXJvfXBeky1/XMju6TkknlVh282/WuFMjbviKqujzx22fthpaIrwcLhk\nlgbv\r\n=HN00\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIA74RyX5siNMy0ExNO6PC9GZ3PYeoKuZ1t5+6ZOCJI5GAiBvjXNbfuv6AKSBZ1u0P2gkC4pVX6eAkJsQXRG5pNMFrg=="}]},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"_npmUser":{"name":"dxinteractive","email":"dxinteractive@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/92green-rxjs_0.7.0_1590116447944_0.7161177361430417"},"_hasShrinkwrap":false},"0.8.0":{"name":"92green-rxjs","version":"0.8.0","description":"Rxjs algorithms","license":"MIT","author":{"name":"Blueflag"},"repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"main":"lib/index.js","scripts":{"prepublish":"yarn build","build":"rm -rf lib && NODE_ENV=production yarn babel src --out-dir lib --ignore '**/__tests__/*.js'","build-all":"yarn build","flow":"blueflag-test flow","flow-coverage":"blueflag-test flow-coverage","lint":"blueflag-test lint","test":"yarn build && yarn jest --maxWorkers=1","test-all":"yarn build && yarn jest --maxWorkers=1 && yarn flow && yarn lint && yarn flow-coverage","watch":"yarn run build -w"},"dependencies":{"@babel/runtime":"^7.1.5"},"devDependencies":{"@babel/cli":"^7.1.2","@babel/core":"^7.1.2","babel-preset-blueflag":"^1.0.0","blueflag-test":"^0.22.0","rxjs":"^6.5.2"},"peerDependencies":{"rxjs":"^6.5.2"},"gitHead":"d595da158fe42ff66cf3eb4904a0e69b502b0020","homepage":"https://github.com/92green/92green-stream#readme","_id":"92green-rxjs@0.8.0","_nodeVersion":"10.15.3","_npmVersion":"lerna/3.14.1/node@v10.15.3+x64 (darwin)","dist":{"integrity":"sha512-2De2ltKPFOcW8Q47xL0EXcOfiPCrushAode8ok2sWEbhpPjW2MEYsGaa9l8xCFc0Cni5RpAFyw5EsLE9a9WYNQ==","shasum":"c5279fecbf6831837309299d2ba2f5eb4e46ac83","tarball":"https://registry.npmjs.org/92green-rxjs/-/92green-rxjs-0.8.0.tgz","fileCount":16,"unpackedSize":26134,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJfLNLXCRA9TVsSAnZWagAAD80P/RIC9EPkTvF9WAYmjR2L\nLk5OGti7UHHzWpylu9hQusC3AqbOt/LSUt6yqbsb2LkVhmOuy+rv94m8adf3\nTCKljb6wlBd24YECQNt581UzS96ugIo3cSH/zSti17HHOI7tcGtiRqopjCM2\nTGFoS2ZNkKOE37Y7+vPkylWLRJg+DiR9T0X3l5lTDxP+9OFJbcan9aE2PQKw\n0bavGceEcXTaebx/qZfCn1M82JXezJG1YXyC/WZSPoYpM/fXMyEbFoEqzLwR\ntORX1nTZ2hqURuFq5yIPh/nJAKswIKGLc8AioH9sMtE49yMfU3y773SlUPiV\nLcnFhcte2GftFelBi1qM8sAZ2XHcG6pwFwc0ke/yEm07Di2phFakfEzEEkNT\ns8dX4eHoxp9jmZCrqA3gp69CD+QeRaLgIittG0ZItAOf1KDBFZppI1+KyCe2\nwWCZCnuUDfc4dm0uPl10j+1QE4RfZCBvL1EwG9fJq3SHEc3Cg0QccujWNPQ2\njrEciaGsuEmvC82LcCNcxyi3DkKEaI2vMt1xXQ27g21A8E5IrIJor/apRgiy\n0stg43XAu8F8GAlUZ5Y0VXQ4h+1/nX8pJX74x5/MgVR8n5/npEEJjpvhlk7o\nth86EBXic1vX7+M3flZrvFL0//GGvG5Ic4o/NTy5FBPAspQ5bARejFavO1wS\np+q2\r\n=0Jfz\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIG6scRMUIF4DZll+Ycf4iodYsoaGaTW4qrkozI8skdoqAiA/ysaTsXvkQoo65c39N6pSqaObwnW3gxRmTVVbZ78HIw=="}]},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"_npmUser":{"name":"dxinteractive","email":"dxinteractive@gmail.com"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/92green-rxjs_0.8.0_1596773078577_0.861762876965537"},"_hasShrinkwrap":false},"0.8.1":{"name":"92green-rxjs","version":"0.8.1","description":"Rxjs algorithms","license":"MIT","author":{"name":"Blueflag"},"repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"main":"lib/index.js","scripts":{"prepublish":"yarn build","build":"rm -rf lib && NODE_ENV=production yarn babel src --out-dir lib --ignore '**/__tests__/*.js'","build-all":"yarn build","flow":"blueflag-test flow","flow-coverage":"blueflag-test flow-coverage","lint":"blueflag-test lint","test":"yarn build && yarn jest --maxWorkers=1","test-all":"yarn build && yarn jest --maxWorkers=1 && yarn flow && yarn lint && yarn flow-coverage","watch":"yarn run build -w"},"dependencies":{"@babel/runtime":"^7.1.5"},"devDependencies":{"@babel/cli":"^7.1.2","@babel/core":"^7.1.2","babel-preset-blueflag":"^1.0.0","blueflag-test":"^0.22.0","rxjs":"^6.5.2"},"peerDependencies":{"rxjs":"^6.5.2"},"gitHead":"4f902e23d9106cea73dad0ce65797ce840c89600","homepage":"https://github.com/92green/92green-stream#readme","_id":"92green-rxjs@0.8.1","_nodeVersion":"12.20.1","_npmVersion":"lerna/3.14.1/node@v12.20.1+x64 (darwin)","dist":{"integrity":"sha512-60UMYgSbDOupGaOWJAh/sizSiz3OxdjOVQ4iMdM7M0V8F6NPh24zoCPvcL0LvXjneQagFeeR4DD8AS2/xflzWQ==","shasum":"aae3f89e2622678c01fd8213e20741514c1c04f5","tarball":"https://registry.npmjs.org/92green-rxjs/-/92green-rxjs-0.8.1.tgz","fileCount":16,"unpackedSize":26154,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJguHTTCRA9TVsSAnZWagAAMKkP/ioUEseO2pCVNWoHSQLJ\nt/54JHuZrXTnvA1lihFDv9SIvuIeRaGcumiQi8J38J6pzXdHGEO4JGsXQnN2\ngmmxgeMgfhX0Zw6gae/J71CmtTFwzEt2+JuV/rkQ1TlNbk9zbCLIP6qGjT8G\nxiwbHAIYnJdssMsgAYbe30ZPTKXpGsYNVvux6qx+IRHrdcFLKIZmelVPSTCM\nGmlGjYVgUzJLOU1WU4cvq2ZsbYGd2qvnMuTVaKjQw5QGjCpyxsCRgRp8vUZk\nYNkfa8e5ttyTlKgOHaGhm3El+u5J5v5K3v28N9w1zp1zuVY4yx85Hgb8Zv+8\nxXU9kDZhbyN+7SnFmboFluoi/JgtdMaq1lSocw25nniXl331YXTxFAiXhzYu\n93W50+W9BOJ6DvvQqH++U2tNpcXe0u5NgZ1U+FjzBTwscsVEKi2ipNvNxGJN\n+wErgOoE4CkYMaRlmO8nLuF3Vd2V/voTR8l/imjG5sD2aVO/7x6UYn46rKXP\n+NVQYqGueLQM6nuYRyx7oeFHSRY2YS4x1aAs1YLSHBKkmPPly3jrgHpv/skZ\nxmsljb3yN97j1mmpqYpkzMsQa77FwgOpEdl/mUf47pxEZGEkwVxgNEgN95p1\nSbarkVZdA4v3Bg5z9yQIG0U48+BYT6HI3IP4WZt9vfcplUW07LwO34W+gDhX\ni/dH\r\n=gYvP\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGQNkBpU/gp7Z4PhtxRJWm1DrdCgI79OJTTk/7klvxNgAiEA8S7Ebcg5ei3wHhuGNBsz/0KWNfknBqClfzIBZ/X3148="}]},"_npmUser":{"name":"dxinteractive","email":"dxinteractive@gmail.com"},"directories":{},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/92green-rxjs_0.8.1_1622701267589_0.6888394769513542"},"_hasShrinkwrap":false},"0.9.0":{"name":"92green-rxjs","version":"0.9.0","description":"Rxjs algorithms","license":"MIT","author":{"name":"Blueflag"},"repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"main":"lib/index.js","scripts":{"prepublish":"yarn build","build":"rm -rf lib && NODE_ENV=production yarn babel src --out-dir lib --ignore '**/__tests__/*.js'","build-all":"yarn build","flow":"blueflag-test flow","flow-coverage":"blueflag-test flow-coverage","lint":"blueflag-test lint","test":"yarn build && yarn jest --maxWorkers=1","test-all":"yarn build && yarn jest --maxWorkers=1 && yarn flow && yarn lint && yarn flow-coverage","watch":"yarn run build -w"},"dependencies":{"@babel/runtime":"^7.1.5"},"devDependencies":{"@babel/cli":"^7.1.2","@babel/core":"^7.1.2","babel-preset-blueflag":"^1.0.0","blueflag-test":"^0.22.0","rxjs":"^6.5.2"},"peerDependencies":{"rxjs":"^6.5.2"},"gitHead":"2b4e455e31ed01a4ebfcd44e7ef7526dba9a041b","homepage":"https://github.com/92green/92green-stream#readme","_id":"92green-rxjs@0.9.0","_nodeVersion":"12.20.1","_npmVersion":"lerna/3.14.1/node@v12.20.1+x64 (darwin)","dist":{"integrity":"sha512-AI00+2Yt5B/ZcVY0DR5BrCwhWD1SjViFwj8z/JYoFlYBpLULCyndXMEZnFYF6PGiTFqHh6lx7e3I1ijebSoR7w==","shasum":"787fdd0b8984255dc57252ce8c5d2b89ad189c34","tarball":"https://registry.npmjs.org/92green-rxjs/-/92green-rxjs-0.9.0.tgz","fileCount":17,"unpackedSize":28200,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJhC5d0CRA9TVsSAnZWagAAkHcP/R/R4c5LxKSst+J6tz4R\nLYQlz6OrVBiqfhEmpxZyvj0roBli1xxK5diE1GV7EXM+hu3BFFFc3Y+ekCB0\nja7Nhv8EttaLgAZ4CbGDVRo065A54CU3svvR92fl5ErcJ9/s14KOa49EDjv5\nyWIhXqVmUyYRUWhrCdTgcH52SFBA1MmxQHyfOz5mJUCcULMPxnVtco1l3TLu\n9fo2EvgMh1jcZ0UqM3c6s/PbQEiiwqu8TgnLoM9cDQdXMNx8JAvsxJYHuCjM\nIbRMp5GCGHfdYXFQL27lgtm6fi4P6nlRDfDJoOW08gkS2pS2m5U/AmrtYCXU\nEIidgPktOszuRjATG2yttRkIEYV6AfYK4QveR77VMVBbsyGZwPmTmaHp6fZJ\nPwmVprrMKYsLT7DkjD7iq70LTOTU5FM7GIRBuBg54vto7O0I41IeAE6/ravy\naPmpKnLhFRzGYPzlU/jeSoHUlrn7RAULpH5u+CFcAFWYmPbxz/bAifbscLVr\n84Bfog6YJjUZC5QOw+JSma3DHI4udvEGH/yIrTadSD7cIdEZuBRSqtSQiunr\nOAXK+9Oq/e7HFcJMs9/EcBlxL/voN+wCEJep1NXCuKrz9Ev+D3SHkkgSRlc4\n3CUk7xHpCWvOvNlqT7QuZy/tEjKsyIOwDeJHmKlbZjaQw6SFUQmTUaXumfBT\nFhXy\r\n=Akfg\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCXEjku1NOVfjI1Fp/KfUtDHUdtLFX+R2KcefpGFCBj2QIgbPYSyc56DSlGJut5uepiyFgooknovyIan9gAPwOG7BE="}]},"_npmUser":{"name":"dxinteractive","email":"dxinteractive@gmail.com"},"directories":{},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/92green-rxjs_0.9.0_1628149619740_0.905656793958006"},"_hasShrinkwrap":false},"0.9.1":{"name":"92green-rxjs","version":"0.9.1","description":"Rxjs algorithms","license":"MIT","author":{"name":"Blueflag"},"repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"main":"lib/index.js","scripts":{"prepublish":"yarn build","build":"rm -rf lib && NODE_ENV=production yarn babel src --out-dir lib --ignore '**/__tests__/*.js'","build-all":"yarn build","flow":"blueflag-test flow","flow-coverage":"blueflag-test flow-coverage","lint":"blueflag-test lint","test":"yarn build && yarn jest --maxWorkers=1","test-all":"yarn build && yarn jest --maxWorkers=1 && yarn flow && yarn lint && yarn flow-coverage","watch":"yarn run build -w"},"dependencies":{"@babel/runtime":"^7.1.5"},"devDependencies":{"@babel/cli":"^7.1.2","@babel/core":"^7.1.2","babel-preset-blueflag":"^1.0.0","blueflag-test":"^0.22.0","rxjs":"^6.5.2"},"peerDependencies":{"rxjs":"^6.5.2"},"gitHead":"4060a15dbd2c792c9b686db56a86f0ca91b257f6","homepage":"https://github.com/92green/92green-stream#readme","_id":"92green-rxjs@0.9.1","_nodeVersion":"12.18.0","_npmVersion":"lerna/3.14.1/node@v12.18.0+x64 (darwin)","dist":{"integrity":"sha512-3l/H9kahyjLFF0La/O6zr3O5ZWlLZ3xyHmrPOboFK15BvYHJ7r0ohKqDb29/fBwyUN4xCJM5kk5RLDpYPiuqmQ==","shasum":"277ce227b86a93d9cebe32e2dfc01f3f14949885","tarball":"https://registry.npmjs.org/92green-rxjs/-/92green-rxjs-0.9.1.tgz","fileCount":17,"unpackedSize":28202,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJhQu5ECRA9TVsSAnZWagAAXCAP/2s+zk532gTS5nUR6jWj\n3PkPuj4NvwcF6XtmHsMP1mpOW4loK0CxbuUJJRzHaPbjzaNgI3tZukxeikpN\nl16mxYdRCUZ6+bjZfNM3+5q0U3309utpsmroQkFA8q4e1npBf33Te+r3hLRn\nPrG2eHUnXDd2qTOQ5wdPHNFpyAUp8e0b6dXC2kSrDAwgXQnc+9GGnAkAsUtG\n0UzAyc2ux+V7Uc0Zf17cD5NlbWwl95PkBCVzUib9MJ8WRe/s2QNJ1hus8fBI\nr7hwJf4y5e0q+Zgw6+vdasqsNYvYx7mdBzpUfuKEGKkN+b6r/LClSEWL66Qi\nZumEfpoya4i5emG72PrQAmsTeY0ogjT4N8c8/Q7urooBcCwcSAUF97/8Or5a\nyBRqftvXuQW2NUP5hv69/CBm5qXSRR6HIlzsV/IV74/RZdBgO+MCoI0822c+\nJO+H7pOiwRBmgEeYIyXfSfIwFrVkZJ7d6eYuXK6EPu23BuiREjGUb26hRwtB\neVUgKUG1cfbt62FRqmOE78LoIdcw5ZXoDvxeqNJ6MToPbPQv0HmF7OxCZ9Zd\nULXhCwPbd39cHHSKDks3mwh4lT5b1d7jtTUc5Mr8Wypnb/+SbXqnhP6v41y6\n2X2XthooskORtkGnfAqgOHXN5vcKsDxyTE8KTQMXCmdnnJYZtgyJssfrAnst\nqkLR\r\n=AhfZ\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEYpsoujOWpMc8fy77L/2veCyiwfvT8ehJXOdVLCp/UAAiAQz/ContudFCwdTbVDvS6rdNRDAMJFEjMmzkUbiYfI7g=="}]},"_npmUser":{"name":"dxinteractive","email":"dxinteractive@gmail.com"},"directories":{},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/92green-rxjs_0.9.1_1631776324424_0.7823868210490843"},"_hasShrinkwrap":false},"0.10.0":{"name":"92green-rxjs","version":"0.10.0","description":"Rxjs algorithms","license":"MIT","author":{"name":"Blueflag"},"repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"main":"lib/index.js","scripts":{"prepublish":"yarn build","build":"rm -rf lib && NODE_ENV=production yarn babel src --out-dir lib --ignore '**/__tests__/*.js'","build-all":"yarn build","flow":"blueflag-test flow","flow-coverage":"blueflag-test flow-coverage","lint":"blueflag-test lint","test":"yarn build && yarn jest --maxWorkers=1","test-all":"yarn build && yarn jest --maxWorkers=1 && yarn flow && yarn lint && yarn flow-coverage","watch":"yarn run build -w"},"dependencies":{"@babel/runtime":"^7.1.5"},"devDependencies":{"@babel/cli":"^7.1.2","@babel/core":"^7.1.2","babel-preset-blueflag":"^1.0.0","blueflag-test":"^0.22.0","rxjs":"^6.5.2"},"peerDependencies":{"rxjs":"^6.5.2"},"gitHead":"59a966a5ef978790f73b910960f8ad758e05d7e5","homepage":"https://github.com/92green/92green-stream#readme","_id":"92green-rxjs@0.10.0","_nodeVersion":"12.20.1","_npmVersion":"lerna/3.22.1/node@v12.20.1+x64 (darwin)","dist":{"integrity":"sha512-Q8iOpM7SyC0+QcBgloiTf8568qFQ8n6U1J1b89bo8++/oGS7dBp3Pa3xygOhGn3BDTwdbE+/1MFsPOMf9H7+Wg==","shasum":"a318884aff90e93e05e6181f82a9abe6f56b6418","tarball":"https://registry.npmjs.org/92green-rxjs/-/92green-rxjs-0.10.0.tgz","fileCount":18,"unpackedSize":30766,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJhue0SCRA9TVsSAnZWagAAbYcP/0yVHkHBLPzXZfQFRIPT\nvvsA9u+Klvfbh6wM2A3n+Ko+1O7zNeuN2G+yprf2SgWFwg4KHfjPjFtbJs1E\nV4G/UcfbpZ8LVQgBWvdhzV/wEHd2aNNG/uIioSP4UUj8RLhlY/u+O6LjqpWK\n7aiQhyISLwVFNiFpflF/8JKIQd2RpGjdav9hBzqBrACCr8xr+Ws4M2oXr3ED\nnwP3cuxZ4vMf4Z6u4QDNZJMkgblziRiNpcqFPoTQX75H/SZgoVCU1KpM9jT+\nLkV/S2voOEcKk2W1kVX9ZzifiVSKhu6nzduThutAKfeWJQVqo6WTSeb/KTyo\neQIGn+1EagLecRrZ2Gcldcvm7Mb6vM6P55i85obs67OhQekR67Qb1teUNgy0\n2dRo1+tPI8s4KT4a4wjJYiCwKSmYnTEVonBvXvANO3BU8eInrnbgvFqlwkqF\nN4n0dWpJkxVxala17L2oWLDS05xnYvcNVnwrXefRE9GHFHACTnmEGnu+1Kr4\nj8pDud4WeW8dUIREINfwhPfywRa/1utvsn/kDF37ko2lzki5I0357rM6xdwv\nO1By4l+JZuDjxYQ54qNmyIQSsZA+NMXw8qtiYYcrfdqJi8HWtbxNrxScce7d\nh+tG7bWA2xrmyrxYE9AvYTt51/JEaPwZz46hrdYqTL5onGX+fDaDwZ1GJjJv\nbUX6\r\n=6fRf\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBObqsjuAF4YHb1i8ccTxkbDz7X50KdtApnSAkhcM2BhAiEAovsGc0FOmdf9CdacucU2IZkehOjjo+kFm0fAXzIsbUM="}]},"_npmUser":{"name":"dxinteractive","email":"dxinteractive@gmail.com"},"directories":{},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/92green-rxjs_0.10.0_1634020338055_0.3317097823089117"},"_hasShrinkwrap":false}},"time":{"created":"2020-05-22T03:00:47.944Z","0.7.0":"2020-05-22T03:00:48.081Z","modified":"2022-04-04T10:25:12.750Z","0.8.0":"2020-08-07T04:04:38.747Z","0.8.1":"2021-06-03T06:21:07.700Z","0.9.0":"2021-08-05T07:47:00.090Z","0.9.1":"2021-09-16T07:12:04.558Z","0.10.0":"2021-10-12T06:32:18.212Z"},"maintainers":[{"name":"dxinteractive","email":"dxinteractive@gmail.com"}],"description":"Rxjs algorithms","homepage":"https://github.com/92green/92green-stream#readme","repository":{"type":"git","url":"git+https://github.com/92green/92green-stream.git"},"author":{"name":"Blueflag"},"bugs":{"url":"https://github.com/92green/92green-stream/issues"},"license":"MIT","readme":"# 92green-rxjs\n\n```\nyarn add 92green-rxjs\n```\n\nRxjs algorithms.\n\n- [multiCache](#multiCache)\n- [memoryCache](#memoryCache)\n- [zipDiff](#zipDiff)\n- [operators/bufferDistinct](#operatorsbufferDistinct)\n- [operators/complete](#operatorscomplete)\n- [dynamodb/batchGetWithRetry](#dynamodbbatchGetWithRetry)\n- [dynamodb/batchWriteWithRetry](#dynamodbbatchWrite)\n- [dynamodb/queryAll](#dynamodbqueryAll)\n- [dynamodb/scanAll](#dynamodbscanAll)\n\n## multiCache\n\nAccepts an array of sources (intended to be things like in-memory caches, database caches and actual data sources) and for each item attempts to retrieve the item from each source sequentially until it is found.\nIt also saves items in caches once found.\nit does not guarantee item order.\n\n```js\nimport {multiCache} from '92green-rxjs';\n\nlet myMemoryCacheOperator = {\n    name: 'memory-cache',\n    load, // operator that loads from cache\n    save, // operator that saves to cache (not needed on data source)\n    clear, // operator that clears item from cache (not needed on data source)\n};\n\n// ^ all of the above operators must accept a payload of {id, item} and return {id, item}\n//   item may be undefined if not known or not found\n\nlet cache = multiCache([\n    myMemoryCacheOperator, // first cache\n    myDatabaseCacheOperator, // deeper cache\n    myDataSource // data source\n])\n\nfrom([\n    {id: 'a'},\n    {id: 'b'},\n    {id: 'c'}\n])\n    .pipe(cache.load);\n\n// Example output observable:\n\n// {id: 'a', item: {id: 'a', name: 'Hi'}, source: 'data-source'}\n// {id: 'b', item: {id: 'b', name: 'Hello'}, source: 'memory-cache'}\n// {id: 'c', item: undefined, source: undefined}\n\n```\n\n## memoryCache\n\nAn rx cache that works a lot like [graphql/dataloader](https://github.com/graphql/dataloader).\n\nUsage with `multiCache`:\n\n```js\nimport {from} from 'rxjs'\nimport {flatMap} from 'rxjs/operators'\nimport {multiCache} from '92green-rxjs';\nimport {memoryCache} from '92green-rxjs';\n\nlet dataSource = {\n    name: 'data-source',\n    load: flatMap(async (payload) => ({\n        ...payload,\n        item: await fetch(payload.id)\n    }))\n};\n\nlet cache = multiCache([\n    memoryCache(),\n    dataSource\n]);\n\nfrom([\n    {id: 'a'},\n    {id: 'b'},\n    {id: 'a'}\n])\n    .pipe(cache.load);\n\n\n// Example output observable:\n\n// {id: 'a', item: {id: 'a', name: 'Hi'}, source: 'data-source'}\n// {id: 'b', item: {id: 'b', name: 'Hello'}, source: 'data-source'}\n// {id: 'a', item: {id: 'a', name: 'Hi'}, source: 'memory-cache'}\n// a is only requested once\n```\n\n## zipDiff\n\nTakes two observables and finds which items exist in one or both, according to a key.\nIt emits items with matching items zipped together on an object: `{a: itemA, b: itemB}`,\nand emits unmatched items on objects with single keys like `{a: itemA}`, `{b: itemB}`.\n\nThe `keyBy` function is called on each item. The data returned is used as an identifier to\nwork out when two items are matching.\n\nA second `keyBy` function can be added if you need a different keyBy function for the second observable.\n\nItems are emitted as early as they can be, so the internal buffer can try and be as small as possible. Pairs of matching items are emitted as soon as they match, and non-matching items are emitted as soon as it's known that it's impossible that there will be a match.\n(e.g. if the buffer contains items from A, and input observable B completes, then it's known there will never be matches for any buffered A's, so they are all emitted)\n\n```js\nimport {zipDiff} from '92green-rxjs';\n\nzipDiff(\n    obsA: Observable,\n    obsB: Observable,\n    keyBy: (item) => any,\n    keyByB?: (item) => any\n): Observable\n```\n\n```js\nzipDiff(obsA, obsB, itemA => itemA.id)\n\n// obsA adds {id: \"1\", name: \"One\"}\n// obsA adds {id: \"2\", name: \"Two\"}\n// obsB adds {id: \"3\", name: \"Three\"}\n// obsB adds {id: \"2\", name: \"Too\"}\n\n// output:\n\n{\n    a: {id: \"2\", name: \"Two\"},\n    b: {id: \"2\", name: \"Too\"}\n}\n\n{\n    a: {id: \"1\", name: \"One\"}\n}\n\n{\n    b: {id: \"3\", name: \"Three\"}\n}\n\n```\n\n## operators/bufferDistinct\n\nBuffers items while the given predicate function returns the same thing, and emits the buffer contents when the given predicate function returns something else or the stream closes. Value comparison is performed using `Object.is()`.\n\nIf `flushObs` is passed, the buffer will be flushed any time `flushObs` emits.\n\n```js\nimport {bufferDistinct} from '92green-rxjs/operators';\n\nbufferDistinct(item => comparisonValue, flushObs: ?Observable)\n```\n\n```js\nobs.pipe(\n    bufferDistinct(item => item.id)\n);\n\n// Obs adds {id: 'a', value: 1}\n// Obs adds {id: 'a', value: 2}\n// Obs adds {id: 'b', value: 3}\n// Obs adds {id: 'c', value: 4}\n// Obs adds {id: 'c', value: 5}\n\n// output:\n\n[\n    {id: 'a', value: 1},\n    {id: 'a', value: 2}\n]\n\n[\n    {id: 'b', value: 3}\n]\n\n[\n    {id: 'c', value: 4},\n    {id: 'c', value: 5}\n]\n```\n\n\n## operators/complete\n\nEmits a single item upon completion of the observable.\n\n```js\nimport {complete} from '92green-rxjs/operators';\n\ncomplete()\n```\n\n```js\nobs.pipe(\n    complete(),\n    tap(() => {\n        console.log(\"I'm done mate\");\n    })\n);\n```\n\n## dynamodb/batchGetWithRetry\n\nTurns AWS `DocClient.batchGet()` into a pipeable observable which accepts an observable of ids and calls `batchGet()`, batching items to 100 at a time and retrying dynamo's `UnprocessedKeys` automatically.\n\n\n```js\nimport {batchGetWithRetry} from '92green-rxjs/dynamodb';\n\nbatchGetWithRetry({\n    docClient: DocClient,\n    tableName: string,\n    returnItems?: boolean\n}): Observable => Observable\n```\n\n```js\nlet keys = [\n    {id: 1},\n    {id: 2},\n    {id: 3}\n];\n\nfrom(keys)\n    .pipe(batchGetWithRetry(...))\n    .toPromise();\n```\n\n\n## dynamodb/batchWriteWithRetry\n\nTurns AWS `DocClient.batchWrite()` into a pipeable observable which accepts an observable of params and calls `batchWrite()`, batching items to 25 at a time and retrying dynamo's `UnprocessedItems` automatically.\n\n\n```js\nimport {batchWriteWithRetry} from '92green-rxjs/dynamodb';\n\nbatchWriteWithRetry({\n    docClient: DocClient,\n    tableName: string,\n    returnItems?: boolean\n}): Observable => Observable\n```\n\n```js\nfrom([{\n    {\n        PutRequest: {\n            Item: {\n                foo: 200\n            }\n        }\n    }\n    ...\n}])\n    .pipe(batchWriteWithRetry(...))\n    .toPromise();\n```\n\n\n## dynamodb/queryAll\n\nTurns AWS `DocClient.query()` into an observable which will by default keep requesting whenever there is more data to be paginated.\n\n\n```js\nimport {queryAll} from '92green-rxjs/dynamodb';\n\nqueryAll(\n    docClient: DocClient,\n    params: Params,\n    feedbackObservable: ?Observable\n): Observable\n```\n\n### dynamodb/scanAll\n\nTurns AWS `DocClient.scan()` into an observable which will by default keep requesting whenever there is more data to be paginated.\n\n\n```js\nimport {scanAll} from '92green-rxjs/dynamodb';\n\nscanAll(\n    docClient: DocClient,\n    params: Params,\n    feedbackObservable: ?Observable\n): Observable\n```\n\n","readmeFilename":"README.md"}