RXJS

基于rxjs发布订阅的事件总线

Axios

采用双队列控制axios请求并发数

事件总线使用示例

发布消息

MsgService.publish(MessageEventSpace.MessageEvent.DEMO, 'RxJS 发布订阅模式实现');

获取订阅

const subscription = MsgService.subscribe(MessageEventSpace.MessageEvent.DEMO).subscribe(data => { console.log('收到消息', data); });

取消订阅

subscription.unsubscribe();

清除消息

MsgService.clear(MessageEventSpace.MessageEvent.DEMO);

axios请求队列示例

import AxiosQueue from '@ikun/common-tool'

limit_num 定义并发限制数 默认写的6个

const limit_num = 6 const axiosQueue = new AxiosQueue(limit_num)

request.use( config => { ..., return axiosQueue.useConfig(config) } )

response.use( response => { const { config } = response axiosQueue.handleResponse(config.url) }, error => { const url = error.config.url axiosQueue.handleResponse(url) } )