{"_id":"@btapai/custom-rxjs-operators","_rev":"5-872326801e6e3497e7a5a670fd138945","name":"@btapai/custom-rxjs-operators","dist-tags":{"latest":"1.0.0"},"versions":{"0.0.1":{"name":"@btapai/custom-rxjs-operators","version":"0.0.1","peerDependencies":{"rxjs":"^6.0.0"},"dependencies":{"tslib":"^2.0.0"},"main":"bundles/btapai-custom-rxjs-operators.umd.js","module":"fesm2015/btapai-custom-rxjs-operators.js","es2015":"fesm2015/btapai-custom-rxjs-operators.js","esm2015":"esm2015/btapai-custom-rxjs-operators.js","fesm2015":"fesm2015/btapai-custom-rxjs-operators.js","typings":"btapai-custom-rxjs-operators.d.ts","metadata":"btapai-custom-rxjs-operators.metadata.json","sideEffects":false,"description":"This library was generated with [Nx](https://nx.dev).","_id":"@btapai/custom-rxjs-operators@0.0.1","_nodeVersion":"14.15.5","_npmVersion":"6.14.11","dist":{"integrity":"sha512-jLC/HEQ4xPzXlQXEGXKaSWgnLWGk1UYcpa7Kaly5yNUbMHCjUkDopBXT0z7foZC7pzVD9V0Zi/FjA+ycz/S74g==","shasum":"b9e5017e272fb15e5b321bde79c0fc5dd93f61c2","tarball":"https://registry.npmjs.org/@btapai/custom-rxjs-operators/-/custom-rxjs-operators-0.0.1.tgz","fileCount":29,"unpackedSize":29493,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgu3Z2CRA9TVsSAnZWagAAlkEP+wQgWRERcMVMSzsjYDgn\n2r+YtmuDj6vqPJv5KBFjakAlVsokcwrn4hvELmEQOWMzwJh7wnuwioWWZMr+\nTIMcfkKwSUxlzWx7XL8ex3pxMAfTbLCNY6JIWjcJoP//MHeRMRABFPiIRq7Q\noIK6MgYM8ISUzAsh1VJJA6Q7wz0dUFPQSIhuhmorIOuKP/EhVa8YRs8ZncQX\nUVC5ZRsbXPpq28CJTzskrh6S3SHCied8ws9w5f9BwbHjyOmD6uU59Nuzo6qi\n5qpLjk4RII4jiPnW/WNbnlhqGx4O+lNNcfecTaF4ONXExsmPqwblVtRmnQa5\nhlveytqULisHzh21uWOWKPSBAy530bQ4cX/XMHybLsDIkUUkhkj0MMumpTzm\nk0d6H+HaNnpgKbhNymGC2qmMoanvsO4LJsLL2vy26L0eWcdq2n85kZBHaFLk\n/FF/G7p79tQtVe6IGRcsupTNt80CgmCFFGdN4H+Zw0TuJ4dzJ9TCEIiQJAED\n7tNyOWrYiL6mhPkgocN/nZZsag99Rj2mGu/ArmQPPQ2tdB3U9O7Kiakasqq5\nKpJHSLKKuNvqlrddZ6N9MkL1Uz6i4hFjaP12ba5B+GLd4pZPh1rMasFYWmbb\n0ucuG67PPbq+Ss5sDvMzQAluT2/Nvx79unpZo0t24l7eKUJKKn90+e3+ZdTG\nUi2W\r\n=WuDi\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCIdd6qQj5KitKQ19xfaqeW6V8JmD5Taq5ukBYC7VKl3AIgIyVVA5pf0Q1OIvrgoZNnuVeo102dMrW2YShQhUCr3wM="}]},"_npmUser":{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"},"directories":{},"maintainers":[{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/custom-rxjs-operators_0.0.1_1622898294319_0.9346748004618128"},"_hasShrinkwrap":false},"0.0.2":{"name":"@btapai/custom-rxjs-operators","description":"A library for my custom rxjs operators","author":{"name":"Balázs Tápai","email":"balazs.tapai1990+npm@gmail.com"},"license":"MIT","version":"0.0.2","peerDependencies":{"rxjs":">= 6.0.0 <= ^7.4.0"},"dependencies":{"tslib":"^2.0.0"},"repository":{"type":"git","url":"git+https://github.com/TapaiBalazs/angular-reusables.git","directory":"libs/custom-rxjs-operators"},"main":"bundles/btapai-custom-rxjs-operators.umd.js","module":"fesm2015/btapai-custom-rxjs-operators.js","es2015":"fesm2015/btapai-custom-rxjs-operators.js","esm2015":"esm2015/btapai-custom-rxjs-operators.js","fesm2015":"fesm2015/btapai-custom-rxjs-operators.js","typings":"btapai-custom-rxjs-operators.d.ts","metadata":"btapai-custom-rxjs-operators.metadata.json","sideEffects":false,"bugs":{"url":"https://github.com/TapaiBalazs/angular-reusables/issues"},"homepage":"https://github.com/TapaiBalazs/angular-reusables#readme","_id":"@btapai/custom-rxjs-operators@0.0.2","_nodeVersion":"14.15.5","_npmVersion":"6.14.11","dist":{"integrity":"sha512-OWDFCYxV6Ac9dkfYgvRQkxM8YUABDxPvN0e/l9ctznIBS+utNYuwKdnLZ9ffuFVc8LuZgnbNsDF8wvJ8Zyz7aA==","shasum":"9905270f517eb47eaa05e20b42c45eae36e97b94","tarball":"https://registry.npmjs.org/@btapai/custom-rxjs-operators/-/custom-rxjs-operators-0.0.2.tgz","fileCount":29,"unpackedSize":95203,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgu9R9CRA9TVsSAnZWagAA578QAIsznufJfiQqPDbXsS9p\ndv+tn3onh4V0BvylBwUgHWpdGue+2cm0gD8qtCxu1EWYoxLKjncNwIDYQGTO\nC3YGqWp152SuAqfUowCHqIg6FDmDoLGVnRwApkf3EW66WIJO6az7M5CJac+n\nI0mmw8ABFFDlSdrvWWRGXV9Nr5zIkXQngWrHMrBuSJA1btmAWtOWwrMhKpSx\nDe+dkcD1t2S3dl0jOFd6Mii/L4YMvr7uxAfo7Bth+H6laFYtHzgK0J/++ZAs\npgqFmTRXaKJI54HmuPYPk/LnfMRQNwFhcvp6GlpdN72XSWSNchLN53LFs0oO\nF9jF1KKugzP/EVqIIKCPAwvMg9fO6EYBpXbHh422O5+fkjUKyyxyucmy4ruG\nYT8qbuWcXlV/pmfQ+BpnT3oB6R34lzqPRgN/phk8ovJFnOM+NYsMOc4s0yBt\nbmu9moc80Y3wru1SxHpyXij5kyylvk+d1HkF5r1dFZfKUmZSmDeUutdK1qku\niqzO7v4dvXS/bvnODbeEVRGcK/c47YxtZ+3k+rEb8eybWcFfC1aWmgDE1p9Z\n9YFK0ACrHsUPsAcTZiJA/Vral4DpW7nutGYIeris1OCLPkNgxmCYK9PD8N5E\n3IbYBN94kJdBYRzEbVMJJs/69wv3a0tZbVmZoz2qEyIBaHGIi9XnZHmTfjhT\n/cxF\r\n=l2/Q\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCqR/D8gTO8IJ/Xgdem3EtDYYNzshHtvHNqxuBMNyaZzAIhALByA/MV/fPmJeKbPkih2mJQyrB6L2Blbxo7276brilL"}]},"_npmUser":{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"},"directories":{},"maintainers":[{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/custom-rxjs-operators_0.0.2_1622922365063_0.026425653172107655"},"_hasShrinkwrap":false},"0.0.3":{"name":"@btapai/custom-rxjs-operators","description":"A library for my custom rxjs operators","author":{"name":"Balázs Tápai","email":"balazs.tapai1990+npm@gmail.com"},"license":"MIT","version":"0.0.3","peerDependencies":{"rxjs":"^6.0.0"},"dependencies":{"tslib":"^2.0.0"},"repository":{"type":"git","url":"git+https://github.com/TapaiBalazs/angular-reusables.git","directory":"libs/custom-rxjs-operators"},"main":"bundles/btapai-custom-rxjs-operators.umd.js","module":"fesm2015/btapai-custom-rxjs-operators.js","es2015":"fesm2015/btapai-custom-rxjs-operators.js","esm2015":"esm2015/btapai-custom-rxjs-operators.js","fesm2015":"fesm2015/btapai-custom-rxjs-operators.js","typings":"btapai-custom-rxjs-operators.d.ts","metadata":"btapai-custom-rxjs-operators.metadata.json","sideEffects":false,"bugs":{"url":"https://github.com/TapaiBalazs/angular-reusables/issues"},"homepage":"https://github.com/TapaiBalazs/angular-reusables#readme","_id":"@btapai/custom-rxjs-operators@0.0.3","_nodeVersion":"14.15.5","_npmVersion":"6.14.11","dist":{"integrity":"sha512-CLUoI6H/PEKElnAa1Jw0XFbhCF9Pi8L3+x32N44sTgEWsbIoA/kywQLDqh38jUH7cRWJCFK/eb3RzdKcbiyDBw==","shasum":"5803545a9ffe8ae2624f6c2c86f932dad0d3f188","tarball":"https://registry.npmjs.org/@btapai/custom-rxjs-operators/-/custom-rxjs-operators-0.0.3.tgz","fileCount":29,"unpackedSize":95191,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgvGlLCRA9TVsSAnZWagAAIcgP/jgYKEtZx3D1m2cndWQ5\nIWVmnXX+TrDoORj70C9jku8Xj8cnuRbQG7N39sbTi1tasgs8aDfg2sYFA5Ey\nZLWKvHYmozYSY4T24/ZyFOZ54PQCAdMFSL9uJpJ3V2/pt/UqLhosNjQunGIs\n8GKtycT+MGB7oCNTZxDrHsLMwahw7TvvPJ2PYmRBk/aVaK9NGDr3lgXCXIqB\njoHbomY6ngUkjvLbd5qGUJhZNH8p3wq/74zl7Yb7JeEYGYeEZka6QpoZ3eR1\n1l2PnGz7j/AwDKgMcNFsNZvpPgoDe0CbkGhxVHsPZU3jN48vLuQdnI5dTQtT\nyUjL86lxQKh4yPzraK/G+uomdpvD1wwe2oojOwNzbaELmuQyAZA7B3xxVSx0\n6E6jc+4jv1BmF4RDqLm+ndjfyr+4ZI+whRMBcwTe9OQXxxXxjNMNa+HgTxdB\ny56UmN+0AfrlX4FxEIfv/vxF84uj6jbDVGk+L4LqKwCR+roucwSbSe4cl8M+\n9KIpMjNAIdFyxO9lwVR+LueamrVRj2btEAtYES4qVBlK4jGw/ni+BYebb1UT\nnAqV9e3pY9cD92kzaRu4sXrllIRbRCn7Gidl5D1o1IwX8GDWPZo7PVnPwuOV\nP1j4KFMiMCcaVmOrgR+FLuSQ/V4o9okRhdW+e257qSKK1KNjQ8r/lI1aPc3w\nyzR8\r\n=uEoN\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDxcdHXeboAaiu7tfW8Zz4GCE+30b0w+BAzpGZMqZrwaQIhAO38eikqK6CKoSW/FNTvQA+yoHTMAYp3xirpRu0Q6aQN"}]},"_npmUser":{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"},"directories":{},"maintainers":[{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/custom-rxjs-operators_0.0.3_1622960459865_0.39118401872838326"},"_hasShrinkwrap":false},"0.0.4":{"name":"@btapai/custom-rxjs-operators","description":"A library for my custom rxjs operators","author":{"name":"Balázs Tápai","email":"balazs.tapai1990+npm@gmail.com"},"license":"MIT","version":"0.0.4","peerDependencies":{"rxjs":"^6.0.0"},"dependencies":{"tslib":"^2.0.0"},"repository":{"type":"git","url":"git+https://github.com/TapaiBalazs/angular-reusables.git","directory":"libs/custom-rxjs-operators"},"main":"bundles/btapai-custom-rxjs-operators.umd.js","module":"fesm2015/btapai-custom-rxjs-operators.js","es2015":"fesm2015/btapai-custom-rxjs-operators.js","esm2015":"esm2015/btapai-custom-rxjs-operators.js","fesm2015":"fesm2015/btapai-custom-rxjs-operators.js","typings":"btapai-custom-rxjs-operators.d.ts","metadata":"btapai-custom-rxjs-operators.metadata.json","sideEffects":false,"bugs":{"url":"https://github.com/TapaiBalazs/angular-reusables/issues"},"homepage":"https://github.com/TapaiBalazs/angular-reusables#readme","_id":"@btapai/custom-rxjs-operators@0.0.4","_nodeVersion":"14.15.5","_npmVersion":"6.14.11","dist":{"integrity":"sha512-NcFtnUnn565wphL+y6e+R8QUIH8Utab3w8QeY90AIMRGRo5EN/PydgPC25PfNtCc3CwJyqfozIQ//YEwMAQEPA==","shasum":"1e1056ef13cac8c48b7e058339d5b15e37c081e4","tarball":"https://registry.npmjs.org/@btapai/custom-rxjs-operators/-/custom-rxjs-operators-0.0.4.tgz","fileCount":33,"unpackedSize":97766,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgw7AgCRA9TVsSAnZWagAAJ3IQAJAH/ZMA7FjIU2Ppeqid\n70Eo11hCG7gL5KCV/Q8wts79UXSiSoo2DyyJE/LjILYjdiHPP2HeNA297kYX\nbQnGyodod08r/232hLtPK4+6ZYxBfjyzDpfXCMPQH1KRddCpfURSlpbFVV3B\nKI/su1Fr/QZ3O0/7IHUx7+Ld5dbNDBV0UuB0K/X3cJ2Xd6HCEYHIiOPenYs5\nvyOsY1aZfF5rb9V6crhfD3Y3q5Q3K6sUOc1+vEN8s4M3iHVAHf82WHE0R1t1\n5gHxWLnGndC9y9bGv6Goz8MC4O/qimm6cN8EMDKghEeBrKIEY3g5tNzDS02z\nmiHdNuNDVvPyXrJ3oJ16dIKwndy36JmObgwn7d3EePc069WFWxUgML/ouQHq\nn1olIFvTvNqIqSl6/+/FraCiabqHiNXurcrGRcdbl5CqpwADqp33h52hFGdM\nBiFFgFgWkj8p0oAUagDnXGHP0CTa7Hi9m3bVOwZj49v5SrbOY7OHT6HJHIIU\nEWxEq1CE/fgRvmwAnnU5Zfd/kcOPM36LXzeSFqsQW5p7QiwklWZ6l3FfZQT3\nfV4UeIkkdVSTvaFLalyrCUTRBNVRIbIoX3s1SXq4c56P5J2fVLnbS3XbcCrx\nPGaqAk1uzmyVWIBzzsKchwnVIy2q0oakHeNxrav77hSqEHsYA0llXKlWGSRo\nmPdp\r\n=FXII\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC+mrb60912d2ACz8+3v9urS1B8VGKyVaHPiARYKEi/SgIhAPEBQbRJrVhXPgZiDC8piZ5u+6IUNRA/9V1LrwpXorfF"}]},"_npmUser":{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"},"directories":{},"maintainers":[{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/custom-rxjs-operators_0.0.4_1623437344405_0.808572549956635"},"_hasShrinkwrap":false},"1.0.0":{"name":"@btapai/custom-rxjs-operators","description":"A library for my custom rxjs operators","author":{"name":"Balázs Tápai","email":"balazs.tapai1990+npm@gmail.com"},"license":"MIT","version":"1.0.0","peerDependencies":{"rxjs":"^6.0.0"},"dependencies":{"tslib":"^2.0.0"},"repository":{"type":"git","url":"git+https://github.com/TapaiBalazs/angular-reusables.git","directory":"libs/custom-rxjs-operators"},"main":"bundles/btapai-custom-rxjs-operators.umd.js","module":"fesm2015/btapai-custom-rxjs-operators.js","es2015":"fesm2015/btapai-custom-rxjs-operators.js","esm2015":"esm2015/btapai-custom-rxjs-operators.js","fesm2015":"fesm2015/btapai-custom-rxjs-operators.js","typings":"btapai-custom-rxjs-operators.d.ts","metadata":"btapai-custom-rxjs-operators.metadata.json","sideEffects":false,"bugs":{"url":"https://github.com/TapaiBalazs/angular-reusables/issues"},"homepage":"https://github.com/TapaiBalazs/angular-reusables#readme","_id":"@btapai/custom-rxjs-operators@1.0.0","_nodeVersion":"14.15.5","_npmVersion":"6.14.11","dist":{"integrity":"sha512-jIdXLXWgeAewgv+zHSVadP4/f7+t8iRr5HFYTWlOz8GtF++KAI6tEJ7T1mhf/Jzw/T1t8VEq76/3j8Tm+Vtcpw==","shasum":"2c23a46321ec34f3c2fb649fa2dba78b437ea821","tarball":"https://registry.npmjs.org/@btapai/custom-rxjs-operators/-/custom-rxjs-operators-1.0.0.tgz","fileCount":33,"unpackedSize":98889,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJgw7MlCRA9TVsSAnZWagAABusP/2aioKpdB/V812bWEMdG\nthR4uS03DWWEjpHN5EkTBI89kcdvWOYiXN/U27FwSMhpoELRFNxQqYtS7pPp\nsTgnoAP73cigmiBVx2sThYLCjKJ7w7rAYcYmDQn3eXULcQeujGbaGJ2to3Ry\ntDSJoDXCtqiNn7yxKe2s0VwJRzlA8pYjhFluDJ7wZH6Lj9h4O8WpRVUSVihw\n76yWIG4BP1rtiy/guSpxfKw3/7QaP0h1SicX4cEz3ebUgWOXzYteXU7EHt3i\naVLsMKi9fkrx2Gul1kRVbYK8XENzmVUnlpxOe34e7ADhHaNF0qUt/jURXEDM\nYjM82vQfrI4pPw608M/eBoGarMJF/3Vk6irKbgzUmJTLP3zHdrHjuhR0mQAP\nMw54U4WvxgfwQFlBkRgT5VAGOEVD7DJKLJzT/Q09yQsiUx5Casz6Or2S35tu\nMyeBpAvSVMUMo5MHErByYWM2jFA0ciMgpp4YMhriCmeVGF+NylHzVYKTkg2y\nk13F9u2neaBPTWKKfFcVSv45RP481jPJTF6hgOsu0QOI3zL/euiYgVLfMsFd\ndxscZ8AsgTAmrtZHqbSBWfzdzo827EPKVTimWLMWxg5JEQ//efjoIq0qzDvz\ny8Vy0vCmT1SMfbkRbpMgAJwJl9jbdypCdAgl71WATdPoB1iCZqXq/JvgHizb\nKH9z\r\n=s1qy\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBFBamISOZGLcltCLMYadjkfkhY5MLbsE1ewSiCcW7rTAiB3EodTJUjaWmOfoHDMpUgMFXLq2SC/NW0cxaSZB4RCIQ=="}]},"_npmUser":{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"},"directories":{},"maintainers":[{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/custom-rxjs-operators_1.0.0_1623438117337_0.11135531903318907"},"_hasShrinkwrap":false}},"time":{"created":"2021-06-05T13:04:54.264Z","0.0.1":"2021-06-05T13:04:54.463Z","modified":"2022-04-04T20:52:18.301Z","0.0.2":"2021-06-05T19:46:05.206Z","0.0.3":"2021-06-06T06:20:59.990Z","0.0.4":"2021-06-11T18:49:04.516Z","1.0.0":"2021-06-11T19:01:57.464Z"},"maintainers":[{"name":"btapai","email":"balazs.tapai1990+npm@gmail.com"}],"description":"A library for my custom rxjs operators","readme":"# @btapai/custom-rxjs-operators\n\nA collection of useful rxjs operators created by [Balázs Tápai](https://tapaibalazs.dev).\n\n## FILO Queue\n\nFirst in, last out queue operator.\n\n```typescript\nimport { timer, from } from 'rxjs';\nimport { take } from 'rxjs/operators';\nimport { filoQueue } from '@btapai/custom-rxjs-operators';\n\nconst source$ = from([1, 2, 3, 4, 5]);\nconst emitter$ = timer(0, 1000).pipe(take(6));\n\nsource$.pipe(filoQueue(emitter$)).subscribe(res => {\n  console.log(res);\n});\n// emits in reverse order:\n// 5 after 1 sec\n// 4 after 2 sec\n// 3 after 3 sec\n// 2 after 4 sec\n// 1 after 5 sec\n// undefined\n```\n\nTakes a source observable, and an emitter observable. The result observable emits every time when the emitter observable emits. It always emits the value that was last added to the queue.\n\nIf the queue is empty, but the emitter emits, the result observable emits undefined.\n\nIf the `emitQueue` property in the passed configuration is set to true, the result observable emits every time when the queue changes.\n\n```typescript\nimport { timer, from } from 'rxjs';\nimport { take } from 'rxjs/operators';\nimport { filoQueue } from '@btapai/custom-rxjs-operators';\n\nconst source$ = from([1, 2, 3, 4, 5]);\nconst emitter$ = timer(0, 1000).pipe(take(6));\n\nsource$.pipe(filoQueue(emitter$, { emitQueue: true })).subscribe(res => {\n  console.log(res);\n});\n\n// [1]\n// [1, 2]\n// [1, 2, 3]\n// [1, 2, 3, 4]\n// [1, 2, 3, 4, 5]\n// [1, 2, 3, 4]\n// [1, 2, 3]\n// [1, 2]\n// [1]\n// []\n// []\n```\n\n\n## FIFO Queue\n\nFirst in, first out queue operator.\n\n```typescript\nimport { timer, from } from 'rxjs';\nimport { take } from 'rxjs/operators';\nimport { fifoQueue } from '@btapai/custom-rxjs-operators';\n\nconst source$ = from([1, 2, 3, 4, 5]);\nconst emitter$ = timer(0, 1000).pipe(take(6));\n\nsource$.pipe(fifoQueue(emitter$)).subscribe(res => {\n  console.log(res);\n});\n// emits in reverse order:\n// 1 after 1 sec\n// 2 after 2 sec\n// 3 after 3 sec\n// 4 after 4 sec\n// 5 after 5 sec\n// undefined\n```\n\nTakes a source observable, and an emitter observable. The result observable emits every time when the emitter observable emits. It always emits the value that was first added to the queue.\n\nIf the queue is empty, but the emitter emits, the result observable emits undefined.\n\nIf the `emitQueue` property in the passed configuration is set to true, the result observable emits every time when the queue changes.\n\n```typescript\nimport { timer, from } from 'rxjs';\nimport { take } from 'rxjs/operators';\nimport { fifoQueue } from '@btapai/custom-rxjs-operators';\n\nconst source$ = from([1, 2, 3, 4, 5]);\nconst emitter$ = timer(0, 1000).pipe(take(6));\n\nsource$.pipe(fifoQueue(emitter$, { emitQueue: true })).subscribe(res => {\n  console.log(res);\n});\n\n// [1]\n// [1, 2]\n// [1, 2, 3]\n// [1, 2, 3, 4]\n// [1, 2, 3, 4, 5]\n// [1, 2, 3, 4]\n// [1, 2, 3]\n// [1, 2]\n// [1]\n// []\n// []\n```\n","readmeFilename":"README.md","homepage":"https://github.com/TapaiBalazs/angular-reusables#readme","repository":{"type":"git","url":"git+https://github.com/TapaiBalazs/angular-reusables.git","directory":"libs/custom-rxjs-operators"},"author":{"name":"Balázs Tápai","email":"balazs.tapai1990+npm@gmail.com"},"bugs":{"url":"https://github.com/TapaiBalazs/angular-reusables/issues"},"license":"MIT"}