Newline Delimited JSON Stream Iterator for json streams in the browser

ndjson-iterator.js

const response = await fetch(`http://localhost:8080/stream`, {
  method: 'get',
  headers: {
    Authorization: `Bearer SomeToken`
  }
})

for await (const value of ndJsonIterator(response.body)) {
  console.log(value)
}

async function* ndJsonIterator (stream) {
  const decoder = new TextDecoder()
  const reader = stream.getReader()

  try {
    while (true) {
      const {done, value} = await reader.read()
      if (done) return
      const json = decoder.decode(value, {stream: true}).trim().split('\n')
      if (!json.length) continue
      for (const line of json) {
        try {
          yield JSON.parse(json)
        } catch (err) {
          console.error('Failed to parse json line', line)
        }
      }
    }
  }
  finally {
    reader.releaseLock()
  }
}