Method processBuffer

packages/utils/src/internals/sitemap.ts:54–77

(input: string, finalize: boolean)

    }

    private processBuffer(input: string, finalize: boolean): void {
        this.buffer += input;

        if (finalize || this.buffer.includes('\n')) {
            const parts = this.buffer
                .split('\n')
                .map((part) => part.trim())
                .filter((part) => part.length > 0);

            if (finalize) {
                for (const url of parts) {
                    this.push({ type: 'url', loc: url } satisfies SitemapItem);
                }

                this.buffer = '';
            } else if (parts.length > 0) {
                for (const url of parts.slice(0, -1)) {
                    this.push({ type: 'url', loc: url } satisfies SitemapItem);
                }

                this.buffer = parts.at(-1)!;
            }
        }
    }
}

class SitemapXmlParser extends Transform {