fetch-event-source 封装

fetch-event-source是一个基于Fetch API和EventSource API的封装，用于在客户端向服务器发送请求并接收服务器推送的数据流。可以通过以下代码进行封装：

function fetchEventSource(url, options, onMessage, onError) {
  const source = new EventSource(url, options);

  source.onmessage = (event) => {
    onMessage(JSON.parse(event.data));
  };

  source.onerror = (error) => {
    onError(error);
  };

  return {
    close() {
      source.close();
    },
  };
}

使用时，可以传入请求的URL、Fetch API的配置选项、onMessage和onError回调函数。其中，onMessage用于处理接收到的数据流，onError用于处理错误信息。该函数会返回一个对象，其中包含close方法，用于关闭数据流连接。

示例代码：

const url = 'https://example.com/stream';
const options = {
  headers: {
    'Authorization': 'Bearer token',
  },
};
const stream = fetchEventSource(url, options, onMessage, onError);

function onMessage(data) {
  console.log(data);
}

function onError(error) {
  console.error(error);
}

// 关闭连接
setTimeout(() => {
  stream.close();
}, 60000);

上述代码会向'https://example.com/stream'发送请求，如果连接成功，则会接收来自服务器的数据流，并调用onMessage回调函数进行处理。如果连接失败，则会调用onError回调函数处理错误信息。在适当的时候，可以通过调用close方法来关闭数据流连接。