flatgeobuf/examples/node/streamtest.js

import { geojson } from 'flatgeobuf';

function nodeToWeb(nodeStream) {
    let destroyed = false;
    const listeners = {};

    function start(controller) {
        listeners.data = onData;
        listeners.end = onData;
        listeners.end = onDestroy;
        listeners.close = onDestroy;
        listeners.error = onDestroy;
        for (const name in listeners) nodeStream.on(name, listeners[name]);

        nodeStream.pause();

        function onData(chunk) {
            if (destroyed) return;
            controller.enqueue(chunk);
            nodeStream.pause();
        }

        function onDestroy(err) {
            if (destroyed) return;
            destroyed = true;

            for (const name in listeners) nodeStream.removeListener(name, listeners[name]);

            if (err) controller.error(err);
            else controller.close();
        }
    }

    function pull() {
        if (destroyed) return;
        nodeStream.resume();
    }

    function cancel() {
        destroyed = true;

        for (const name in listeners) nodeStream.removeListener(name, listeners[name]);

        nodeStream.push(null);
        nodeStream.pause();
        nodeStream.destroy();
    }

    return new ReadableStream({ start: start, pull: pull, cancel: cancel });
}

async function streamtest() {
    const response = await fetch('https://flatgeobuf.org/test/data/UScounties.fgb');
    for await (const feature of geojson.deserialize(nodeToWeb(response.body)))
        console.log(JSON.stringify(feature, undefined, 1));
}

streamtest();