{"_id":"@eduardorothdev/rxjs-mqtt","_rev":"14-460a2a3c49de75ea799905f1268b355d","name":"@eduardorothdev/rxjs-mqtt","dist-tags":{"latest":"1.1.2"},"versions":{"1.0.0":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.0","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.0","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"5ae1e56affb1b3d72551849a022920c2b91e5e7f","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.0.tgz","fileCount":13,"integrity":"sha512-pBX2ONTXaFV4yBiDuHxHV2OKaA/C/gU+IP4yrzLRt6UK2YRkMbPukjkNfDyc0kX4iVQAmA526y42hC+1nvQg7Q==","signatures":[{"sig":"MEQCIBwKLe89XYC8lQ51rAWhgRpULqhr3/cUNFN4ZtMt02/8AiAyWxpdfeLkEVdZB8W7kdx4svKkMWd4POIeV5s4JOR97A==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":20708},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"a9bd2359d437c3c9692244a3ecd97e11fb24d729","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.0_1726511257708_0.8821133612149532","host":"s3://npm-registry-packages"}},"1.0.1":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.1","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.1","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"5625610fed51021abb6342afbab7e2d7434b4601","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.1.tgz","fileCount":13,"integrity":"sha512-sfB20fx9CANcfMgmCCUWE0L/1/+K1r87maUIn3pXAbGln6xWepYRZqmkPQRANkspNRx5h02Tyu1J5HRx+tz54g==","signatures":[{"sig":"MEUCIBCB4lzg5mYK6+CLKwYfVSdrQ6rbnpLfE2IRArkaJotmAiEAj//JHmSaEAyxF28uKBuWUTGQ7PlKrmfNKKM5riEWjKE=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21243},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"1e9e78d9af65d57c033ff874f857f68a1a735918","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.1_1726524810892_0.9983599454097223","host":"s3://npm-registry-packages"}},"1.0.2":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.2","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.2","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"e22478d7d17da03f2cdaf280dd599b59d9ca6330","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.2.tgz","fileCount":13,"integrity":"sha512-Sap2gJniKUd8CririaVDMbUYOKZynrmwe2M7Fb+D/xlJorfvTP1aUuswOfbDGcfcbXrV8Q8RDu4d1FabImh42A==","signatures":[{"sig":"MEYCIQCjVzUTYuSDMS43WmylvAyJWAtiZkwlg2CJ78RrhFFOrwIhAIsyxfdWvsR/C+rS5vdgcJERFWpPbt502N2ynPVgBdvT","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21243},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"1e9e78d9af65d57c033ff874f857f68a1a735918","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.2_1726524823696_0.16065857500918446","host":"s3://npm-registry-packages"}},"1.0.3":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.3","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.3","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"1a8bdcbb65060e8161e916287b7b1939c512b939","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.3.tgz","fileCount":13,"integrity":"sha512-ryy4A1XB/PHNfuwR15UN6p3M1HA9/XoEmTAIspiegrGInKvcXCXCLcGjCX9CK0YNzq0ygRsg2LF2xfhavhbtYA==","signatures":[{"sig":"MEUCIHmC9Flc69hZt8PUANAeYBHtfxkpN2Stt/eW1V6uBIv+AiEAm46BBxrgUf5E70WHyyNtvpoHSKXyjoXDPWo5+Q911rg=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21243},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"1e9e78d9af65d57c033ff874f857f68a1a735918","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.3_1726524850045_0.3022240224167567","host":"s3://npm-registry-packages"}},"1.0.4":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.4","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.4","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"a4be8a69f23d89a2bc237ac519712cf4cdbfcb40","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.4.tgz","fileCount":13,"integrity":"sha512-sWobO7qIXyRS01WBiLS9PVIYKkeZ7LbU0SBkSWHypmSzsmXopZ8Dk4LX1mJgOA6sYNLOk1YkO///Az3CboEn8g==","signatures":[{"sig":"MEQCIGwteo3uqd9idkIos39uV0jlktYLg4U2GhY2ZE5mMPY4AiAN044DgCOiAw/f1Kx/a94TtasT4W2aTyh3QwoCetw1+Q==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21243},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"91ab87edcb579d0364ced778f9340fdee9250165","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.4_1726524880660_0.4612097548335192","host":"s3://npm-registry-packages"}},"1.0.5":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.5","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.5","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"797e45029991bab8a40bf971a0743b91c1747413","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.5.tgz","fileCount":13,"integrity":"sha512-dRxQuGAd01X5rLg1IWe/ht2BxlEPPRWP+qHA3+XRxodQbp2d2iSOao4HNb9nnPZUpa2O5c3EroHoMYjtGOPcAA==","signatures":[{"sig":"MEUCIEFaYTppcd1o3dnEfX8opeargNRPmRtvuC45whXYCOGzAiEAk89MhdntZfiTaqB7ePbbVflo5S1KI0Wk7wWjZkAbv3Y=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21674},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"5ffbb3ae42d60b2464111b99779ff5711bd6dbbf","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.5_1726524955792_0.5771214559413422","host":"s3://npm-registry-packages"}},"1.0.6":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.6","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.6","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"fcd6f31046bf56e5c94ec08b01f0780b87b79125","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.6.tgz","fileCount":13,"integrity":"sha512-HDpkUPBCGbf2WJeXm5UmdLhNrQIl67E3HVqlILdvInR6Lu/3Z3FblindX4QjAugIfuvayhvDJNM0rN9gYN97/A==","signatures":[{"sig":"MEUCIDMhoxPUrltB7HrnjXV1fE58dSwOr+gzj3HYdrrxntU7AiEA/6cpYDF7cwiNPW4SUnBPi1RdlFTYfHsHfBl6sg2iKro=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21794},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"fe6446b02e4be805071482ec558351e0673ccf39","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.6_1726525070805_0.793807797028808","host":"s3://npm-registry-packages"}},"1.0.7":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.7","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.7","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"e5b42e0f33b77cddb7d79879bd6f92a999ceee03","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.7.tgz","fileCount":13,"integrity":"sha512-04eNd03aSUbJ2V2hBdjQNJmgPTZO2K2aOHlqlMeK2e0+h37ZPxtvLuf9riUbbnh2sNi0RikO2ogvm5j6pL6Ocw==","signatures":[{"sig":"MEYCIQDu0NXK+M8XIXc87bR7/DBo0sAOAqgK1GiXqATOKRrwsAIhALwPho9vrJYyblxR9Dq2iYkC8kU0a0zdZ0u2mZMlzlX4","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":21958},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"4d592368d11e3f7cacc53925a46741b4fa2b0169","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.7_1726593976714_0.7260198252245966","host":"s3://npm-registry-packages"}},"1.0.8":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.8","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.8","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"9af7ffb33bd381784f5bc483256ba981bb55a9b1","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.8.tgz","fileCount":13,"integrity":"sha512-tWocfbSx0Ib4JvXqGH26DlbIjC7d2y1PqU3z20tWiYqbpitypvpRr224HmI+fWVzraq+RjMXh5sjE7f6eJDQpA==","signatures":[{"sig":"MEUCIBg+dXE8xYbszQWaManhp1EX61Z2WBxo9qZNEkU/ddpgAiEA2RmeMxfvAjVUqEp75PDTesfx70X9lDpcCHRdzo1dLYU=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":22106},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"7cd5d217fe307e1248f2f2b5a21e120a4b92bca0","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.8_1726595225649_0.08957618620510566","host":"s3://npm-registry-packages"}},"1.0.9":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.9","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.9","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"630a637df6eb97a3e7f628d33d3b435223620dc1","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.9.tgz","fileCount":13,"integrity":"sha512-wrMAHHfw/e4BUo6UGuWJnLRwPMEDntoUz70M12rV4Wls4fGM01p+x77SKhSXgbn3MS8Lzk5PZRxybU8dI/qWFQ==","signatures":[{"sig":"MEUCIQDHDZpuIGUELVmLsCXd+7pcNx8gxAQoYcH8rBDBeJKdAwIgLji9Rdo/Gzh7n3p4BFXmM6AP9PLSdYkrXkVbEfJypvc=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":22561},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"1c6f58fbf384644fc9121c565e89d35feca439fa","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.9_1726596690394_0.20478867048713756","host":"s3://npm-registry-packages"}},"1.0.10":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.10","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.10","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"5802e9dd500a16023e933d1b85dbe596ec658b57","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.10.tgz","fileCount":13,"integrity":"sha512-hLrwrRDllyCFfaF/fFdZ12a3dUmCqO1Atbok82rz0KzH0vHKn6jUDKTikLgL2fw6zyLV9CHuvcrdNaJkam5/aQ==","signatures":[{"sig":"MEUCIQCd8Vvi3SOnweMttT1L4gL7YNvteWfGO8pQbQ7eCSJOaQIgKRtHgPmQKfi2cdFkEFzR8Q9b2N1A6/oMizA9+8bOCrg=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":22578},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"7f36b6e99798d88328a90caea2d06e6e4150f9ff","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.10_1727378078095_0.7941820665137398","host":"s3://npm-registry-packages"}},"1.0.11":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.11","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.11","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"f063a979bc01f8669dca638cb61ddc78002ffb70","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.11.tgz","fileCount":13,"integrity":"sha512-0zrtgBIO8VMlLeXhEYyB/aBZBuS2zruEU+g4wfNgkm09RP8Tiy6dRtzbIwzePSQnoOrMw/DQlSkEclxAuSWTeA==","signatures":[{"sig":"MEUCIGevMnEPBajrvgQp9teO+dBIEGpTo0DjWrDm9d2ayQ6tAiEA8m5OjQAZXQWUZAvckRCnhdfgLrQ5VUePW5B6S3U6r20=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":22594},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"45ee25e67da157da07ee0d4dfe33de771590b1ec","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.11_1727378184451_0.29548241059456015","host":"s3://npm-registry-packages"}},"1.0.12":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.0.12","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.0.12","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"f507bc59e6f56a773ae0a8d85894e41425db959a","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.0.12.tgz","fileCount":13,"integrity":"sha512-sK6EATKCQqEiZhMhQfjVTsqFsBFeOfTRbD5TfEHuksY769Q+z7nVGazFo53JbdQ2mV/Q/KiZU8z+LOGUWniIFQ==","signatures":[{"sig":"MEUCIQDws/08O3gRtnoSJ5CAy+apf+7TriW5+cJRvR6xS/cwYQIgfMthCpkFrqHU6a6JCSLlDWcNq3f7PafOOyYbodsc/98=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":22562},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"1cd756249e1d7032c0508f256b161dde824a3730","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.0.12_1727379005739_0.5958304818823352","host":"s3://npm-registry-packages"}},"1.1.0":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.1.0","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","_id":"@eduardorothdev/rxjs-mqtt@1.1.0","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"dist":{"shasum":"7f765b7bd6094a57305bf4a91f22fcb3d91febc5","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.1.0.tgz","fileCount":13,"integrity":"sha512-xW3M7zuAy9oPz5dlVJkrZWkesArBcaPevvKQ+PbGaHA98f27GU1T8wkC9qF8rmrheZXb8Pr6J1oI+ZVuB1ykpw==","signatures":[{"sig":"MEYCIQC1T4+M5dUavWkwj27Ft28djs5ZETdpqC+CMYMg6UnHQwIhAKj0DXSZCF0/EQWy1URCKzMC457lAkPfcLLtATsEMWDt","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":23182},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./types":"./dist/types/index.js","./parsers":"./dist/parsers/index.js"},"gitHead":"f51dc89cf99ebd0cd57f0b439b812d486f6d451c","scripts":{"build":"tsc -p tsconfig.json"},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"repository":{"url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git","type":"git"},"_npmVersion":"10.8.3","description":"RxJS wrapper for MQTT. Based on async-mqtt","directories":{},"_nodeVersion":"22.1.0","dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"_hasShrinkwrap":false,"devDependencies":{"typescript":"^5.6.2","@types/node":"^22.5.4"},"_npmOperationalInternal":{"tmp":"tmp/rxjs-mqtt_1.1.0_1727457453392_0.8177280154771485","host":"s3://npm-registry-packages"}},"1.1.2":{"name":"@eduardorothdev/rxjs-mqtt","version":"1.1.2","description":"RxJS wrapper for MQTT. Based on async-mqtt","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"tsc -p tsconfig.json"},"repository":{"type":"git","url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git"},"keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"author":{"name":"Eduardo Roth"},"license":"MIT","bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","devDependencies":{"@types/node":"^22.5.4","typescript":"^5.6.2"},"dependencies":{"mqtt":"^2.6.3","rxjs":"^7.8.1"},"exports":{".":"./dist/index.js","./parsers":"./dist/parsers/index.js","./types":"./dist/types/index.js"},"_id":"@eduardorothdev/rxjs-mqtt@1.1.2","gitHead":"8061837dc404791c39ea7a6388c597ee53a5577a","_nodeVersion":"22.1.0","_npmVersion":"10.8.3","dist":{"integrity":"sha512-EjfFoka/LdwD5fyHE0QUHbGj9HpltyPnlYDde2mwKw8d285vx62mjkBNi9r5j3AQvTTi7fZ3xeBLfWuNhdlqKQ==","shasum":"1bd0f63a4c66ffe86712b8eafcea51a1718ba152","tarball":"https://registry.npmjs.org/@eduardorothdev/rxjs-mqtt/-/rxjs-mqtt-1.1.2.tgz","fileCount":13,"unpackedSize":23239,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDqfX5gzbswSUoywvdoh058SOG+Euabf9LcAF5MLlnJKQIgQaWW55ujEDSDE9ZZ6xr17epdNmN+fWHGDA4o4qvHTXg="}]},"_npmUser":{"name":"eduardoroth","email":"earoth88@gmail.com"},"directories":{},"maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rxjs-mqtt_1.1.2_1727457780455_0.4121338756828212"},"_hasShrinkwrap":false}},"time":{"created":"2024-09-16T18:27:37.630Z","modified":"2024-09-27T17:23:00.849Z","1.0.0":"2024-09-16T18:27:37.894Z","1.0.1":"2024-09-16T22:13:31.071Z","1.0.2":"2024-09-16T22:13:43.862Z","1.0.3":"2024-09-16T22:14:10.192Z","1.0.4":"2024-09-16T22:14:40.816Z","1.0.5":"2024-09-16T22:15:55.953Z","1.0.6":"2024-09-16T22:17:51.024Z","1.0.7":"2024-09-17T17:26:16.896Z","1.0.8":"2024-09-17T17:47:05.833Z","1.0.9":"2024-09-17T18:11:30.542Z","1.0.10":"2024-09-26T19:14:38.296Z","1.0.11":"2024-09-26T19:16:24.787Z","1.0.12":"2024-09-26T19:30:05.931Z","1.1.0":"2024-09-27T17:17:33.605Z","1.1.2":"2024-09-27T17:23:00.623Z"},"bugs":{"url":"https://github.com/eduardoRoth/rxjs-mqtt/issues"},"author":{"name":"Eduardo Roth"},"license":"MIT","homepage":"https://github.com/eduardoRoth/rxjs-mqtt#readme","keywords":["mqtt","async","rxjs","observable","publish","subscribe"],"repository":{"type":"git","url":"git+https://github.com/eduardoRoth/rxjs-mqtt.git"},"description":"RxJS wrapper for MQTT. Based on async-mqtt","maintainers":[{"name":"eduardoroth","email":"earoth88@gmail.com"}],"readme":"# @eduardorothdev/rxjs-mqtt\n\nRxJS Wrapper for [mqtt](https://www.npmjs.com/package/mqtt) with TS support. Based on [async-mqtt](https://www.npmjs.com/package/async-mqtt)\n\n## Install\n\n```\nnpm i @eduardorothdev/rxjs-mqtt\n```\n\n## Using it\n\nYou first need to call and await the connect function, which will return a `MqttClient` object with updated methods.\n\nThe methods for this MqttClient object are the same as one generated with `mqtt` but has the following methods modified:\n\n- **Promises**\n  - `.publish()`\n  - `.subscribe()`\n  - `.unsubscribe()`\n  - `.end()`\n- **Observables**\n  - `.on()`\n    - This method returns an observable that emits any time it receives from the event being listened.\n  - `.onJsonMessage<T>()` **New method**\n    - This is a helper method that extends the `on()` one, getting only the events of `message` sent from the MQTT server, and parsing them to JSON\n    - `<T>` is the interface or type that the method will try to parse the received message\n\nIn addition to those, I added two more Operator Function helpers that you can chain to the `pipe` method of the Observable returned, that will help you easily parse the received events.\n\n- **Helpers**\n  - `parsePayload<T>(parser: (buffer: Buffer) => T | string = (buffer: Buffer) => buffer.toString()`\n    - This Operator Function helper allows you to parse the bytes payload received from the MQTT event with a custom function that will convert the bytes to anything.\n  - `parsePayloadToJSON()`\n    - This Operator Function helper extends the previous function to easily convert the received bytes to JSON.\n\n### Example code\n\n```ts\nimport { connect } from \"@eduardorothdev/rxjs-mqtt\";\n\ntry {\n  const client = await connect(\"mqtt://test.mosquitto.org\", {\n    //username: 'user',\n    //password: 'pass',\n  });\n  // subscribe to a topic\n  await client.subscribe(\"some/topic/#\");\n  const sub = client\n    .onJsonMessage<{\n      some: string;\n      property: string;\n      mapping: boolean;\n    }>()\n    .pipe(\n      catchError((err) => {\n        // we have to catch the error so the\n        // observable pipe doesn't stop sending messages\n        return of(null);\n      }),\n    )\n    .subscribe((jsonMessage) => {\n      // { some: 'hello', property: 'from mqtt', mapping: true }\n      console.log(jsonMessage);\n    });\n\n  // later you can unsubscribe when needed.\n  // this will unsubscribe from the onJsonMessage observable pipe\n  // not from the topic subscription\n  // sub.unsubscribe();\n\n  // Unsubscribe from the topic subscription\n  // await client.unsubscribe('some/topic/#');\n} catch (err) {\n  // connection/subscription-to-topic errors\n  console.log(err);\n}\n```\n\n## License\n\nLicensed under [MIT](./LICENSE).\n","readmeFilename":"README.md"}