如何获取ndjson响应流

const axios = require('axios');

async function fetchNdjson(url) {
  try {
    const response = await axios({
      method: 'get',
      url: url,
      responseType: 'stream'
    });

    response.data.on('data', (chunk) => {
      const lines = chunk.toString().split('\n');
      lines.forEach((line) => {
        if (line) {
          try {
            const obj = JSON.parse(line);
            console.log(obj);
          } catch (error) {
            console.error('Error parsing JSON:', error);
          }
        }
      });
    });

    response.data.on('end', () => {
      console.log('Stream ended');
    });

    response.data.on('error', (error) => {
      console.error('Stream error:', error);
    });
  } catch (error) {
    console.error('Error fetching data:', error);
  }
}

// 使用示例
fetchNdjson('https://example.com/api/data.ndjson');