Function readableStream

test-src/JsonStreamStringify.spec.ts:39–52

(...args)

}

function readableStream(...args) {
  const stream = new Readable({
    objectMode: args.some(v => typeof v !== 'string'),
  });
  stream._read = () => {
    if (!args.length) {
      return stream.push(null);
    }
    const v = args.shift();
    if (v instanceof Error) return stream.emit('error', v);
    return stream.push(v);
  };
  return stream;
}

describe('JsonStreamStringify', function () {
  this.timeout(10000);