ezs-basics/src/json-parse.js

import JSONStream from 'JSONStream';
import { writeTo } from './utils';

function JSONParse(data, feed) {
    if (!this.handle) {
        const separator = this.getParam('separator', '*');
        this.handle = JSONStream.parse(separator);
        this.handle.on('data', obj => feed.write(obj));
    }
    if (!this.isLast()) {
        writeTo(this.handle,
          data,
          () => feed.end());
    } else {
        this.handle.end();
        process.nextTick(() => {
            feed.close();
        });
    }
}

/**
 * Take `String` and parse JSON and generate objects
 *
 * @name JSONParse
 * @param {String} [separator=*] to split at every JSONPath found
 * @returns {Object}
 * @see https://github.com/dominictarr/JSONStream
 */
export default {
    JSONParse,
};