Function parseStream

src/index.js:246–272

(stream, options, callback = noop)

// @param {options} options The options object
// @param {function} callback The callback function
const parseStream = (stream, options, callback = noop) => {
  if (typeof options === 'function') {
    callback = options;
    options = {};
  }

  const emitter = new events.EventEmitter();

  try {
    const results = [];
    stream
      .pipe(new GCodeLineStream(options))
      .on('data', (data) => {
        emitter.emit('data', data);
        results.push(data);
      })
      .on('end', () => {
        emitter.emit('end', results);
        callback && callback(null, results);
      })
      .on('error', callback);
  } catch (err) {
    callback(err);
  }

  return emitter;
};

// @param {string} file The G-code path name
// @param {options} options The options object