export function gremlinCmdStreamWriter()

in src/stream/writer.ts [18:39]

• 22 lines of code
• 1 McCabe index (conditional complexity)

export function gremlinCmdStreamWriter(config: any) {
  const fileWriteStream = fs.createWriteStream(config.filePath, {
    encoding: 'utf-8',
    flags: 'w',
  });
  return writer.obj(
    (chunck: GraphInfo, enc, callback) => {
      chunck.vertices.forEach(vertex => {
        const cmd = GraphHelper.getAddVertexQuery(vertex);
        fileWriteStream.write(cmd + '\n');
      });
      chunck.edges.forEach(edge => {
        const cmd = GraphHelper.getAddEdgeQuery(edge);
        fileWriteStream.write(cmd + '\n');
      });
      callback();
    },
    callback => {
      fileWriteStream.end(callback());
    }
  );
}