(e)
| 72 | const instance = new target(...args), |
| 73 | openHandler = (e) => {}, |
| 74 | messageHandler = (e) => { |
| 75 | e = new Uint8Array(e.data); |
| 76 | let t = parser(opts); |
| 77 | |
| 78 | // mes_block_delivery |
| 79 | 2e3 < e.length && |
| 80 | (t.on("packet", (e) => { |
| 81 | "publish" === e.cmd && |
| 82 | "/ls_resp" === e.topic && |
| 83 | 1 === e.qos && |
| 84 | qq.push(e.messageId); |
| 85 | }), |
| 86 | t.parse(e)); |
| 87 | }, |
| 88 | closeHandler = (e) => { |
| 89 | instance.removeEventListener("open", openHandler); |
| 90 | instance.removeEventListener("close", closeHandler); |