Function transform

recorded/app/index.js:35–49

(chunk, controller)

function parseNDJSON() {
  return new TransformStream({
    transform(chunk, controller) {
      for (const item of chunk.split('\n')) {
        if (!item.length) continue
        try {
          controller.enqueue(JSON.parse(item))
        } catch (error) {
          // this exception is a common problem that we won't handle in this class:
          // if the arrived data is not completed, it should be stored in memory 
          // until completed
          // 1st msg received - {"name": "er"
          // 2st msg received - "ick"}\n
          // result           {"name": "erick"}\n
        }
      }
    }
  })
}
let counter = 0