SequentialStream.mjs

import Benchmark from "benchmark";
import { Writable } from 'node:stream';
import { XMLParser as FlexParser } from "@nodable/flexible-xml-parser";
import { SequentialStreamBuilderFactory } from "@nodable/sequential-stream-builder";
import { XMLParser as FastParser } from "fast-xml-parser";
import { dirname } from 'node:path';
import { fileURLToPath } from 'node:url';

// compatibility
const __dirname = dirname(fileURLToPath(import.meta.url));

const suite = new Benchmark.Suite("XML Parser benchmark");

import fs from "fs";
import path from "path";
// const fileNamePath = path.join(__dirname, "./assets/ptest.xml");//with CDATA
// const fileNamePath = path.join(__dirname, "./assets/ptest_with_prolog.xml");//with CDATA
const fileNamePath = path.join(__dirname, "./assets/sample.xml");//1.5k
// const fileNamePath = path.join(__dirname, "./assets/midsize.xml");//13m
// const fileNamePath = path.join(__dirname, "./assets/large.xml");//98m
// const xmlData = fs.readFileSync(fileNamePath).toString();
const nullSink = () => new Writable({ write(chunk, enc, cb) { cb(); } });

suite
    .add("Fast XML Parser", function () {
        const xmlData = fs.readFileSync(fileNamePath).toString();
        const parser = new FastParser({
            preserveOrder: true
        })
        const result = parser.parse(xmlData);
        fs.writeFileSync('output_fxp.json', JSON.stringify(result));
    })
    .add("Flexible XML Parser", {
        defer: true,
        fn: function (deferred) {
            const inStream = fs.createReadStream(fileNamePath);
            const outStream = nullSink();
            const parser = new FlexParser({
                OutputBuilder: new SequentialStreamBuilderFactory({ stream: outStream })
            });
            parser.parseStream(inStream).then(() => {
                outStream.end(() => deferred.resolve());
            });
        }
    })



    .on("start", function () {
        console.log("Running Suite: " + this.name);
    })
    .on("error", function (e) {
        console.log("Error in Suite: " + this.name, e);
    })
    .on("abort", function (e) {
        console.log("Aborting Suite: " + this.name, e);
    })
    /*.on('cycle',function(event){
        console.log("Suite ID:" + event.target.id);
    })*/
    // add listeners
    .on("complete", function () {
        for (let j = 0; j < this.length; j++) {
            console.log(this[j].name + " : " + this[j].hz + " requests/second");
        }
    })
    // run async
    .run({ "async": true });