| | |
| | | import { SESSION_KEY } from '../request'; |
| | | import { Local } from '../storage'; |
| | | import { debounce } from 'lodash-es'; |
| | | import { Logger } from '/@/model/logger/Logger'; |
| | | |
| | | export interface SSEOptions { |
| | | /** 重试延迟(ms) */ |
| | |
| | | if (!this.eventSource) return; |
| | | |
| | | this.eventSource.onopen = () => { |
| | | console.log('连接成功'); |
| | | Logger.info('onopen:连接成功'); |
| | | this.callbacks.onOpen?.(); |
| | | }; |
| | | |
| | | this.eventSource.onmessage = (event) => { |
| | | Logger.info('onmessage:\n\n'+ event.data); |
| | | try { |
| | | const data = JSON.parse(event.data); |
| | | // 检查是否是结束标记 |
| | |
| | | }; |
| | | |
| | | this.eventSource.onerror = async (error) => { |
| | | Logger.error('onerror:\n\n'+ error); |
| | | }; |
| | | } |
| | | |