| 24 | queue.delete(msgId) |
| 25 | } |
| 26 | const task = () => { |
| 27 | // 10s 了上个请求还未完成就中断掉 |
| 28 | request?.abort() |
| 29 | if (queue.size > 0) { |
| 30 | // 开始新请求 |
| 31 | request = apis.getMsgReadCount({ params: { msgIds: [...queue] } }) |
| 32 | request.send().then((res) => { |
| 33 | const result = new Map<number, MsgReadUnReadCountType>() |
| 34 | res.forEach((item) => result.set(item.msgId, item)) |
| 35 | eventBus.emit('onGetReadCount', result) |
| 36 | request = null |
| 37 | }) |
| 38 | } |
| 39 | } |
| 40 | |
| 41 | export const initListener = () => { |
| 42 | eventBus.on('onAddReadCountTask', onAddReadCountTask) |