ndjson-with-axios.ts

gistfile1.txt

import axios from 'axios';
import { parse } from 'ndjson';

async function fetchNDJSON(url: string): Promise<void> {
  try {
    const response = await axios({
      method: 'get',
      url: url,
      responseType: 'stream'
    });

    const stream = response.data;

    stream.pipe(parse())
      .on('data', (obj: any) => {
        console.log('Parsed JSON object:', obj);
      })
      .on('error', (error: any) => {
        console.error('Error parsing NDJSON:', error);
      });

  } catch (error) {
    console.error('Error fetching NDJSON:', error);
  }
}

fetchNDJSON('https://example.com/ndjson-endpoint');