import { ArrayIterator } from 'asynciterator'
import JSONSplitTransformer from 'json-split-transformer';

const streamSplitter = new JSONSplitTransformer();

const iterator = new ArrayIterator<string>([
  "{\"time\":1625581",
  "199",
  "479,\"values\":[32,23]}{\"ti",
  "me\":1625581199482,\"values\":[31,12]}"
]);

// New iterator that will emit the objects
// {time: 1625581199479, values: [32, 23]}
// and
// {time: 1625581199482, values: [31, 12]}
const newIterator = iterator
  .map(buffer => buffer.toString())
  // Split up concatenated JSON strings
  .transform<string>({ transform: streamSplitter.transform })
  // Parse each JSON string
  .map(JSON.parse)