Function parseXmlRecords

xml/parse_records.ts:84–104

(
  source: AsyncIterable<string>,
  createCallbacks: (emit: (record: T) => void) => XmlEventCallbacks,
  options: ParseStreamOptions = {},
)

 * ```
 */
export async function* parseXmlRecords<T>(
  source: AsyncIterable<string>,
  createCallbacks: (emit: (record: T) => void) => XmlEventCallbacks,
  options: ParseStreamOptions = {},
): AsyncGenerator<T> {
  const buffer: T[] = [];
  const callbacks = createCallbacks((record) => buffer.push(record));
  const { tokenizer, parser } = createXmlPipeline(options, callbacks);

  // Fail-fast contract: a drain-then-throw approach interacts poorly with
  // consumer break, so we propagate immediately and drop the chunk's
  // pending records.
  for await (const chunk of source) {
    tokenizer.process(chunk, parser);
    for (let i = 0; i < buffer.length; i++) yield buffer[i]!;
    buffer.length = 0;
  }
  tokenizer.finalize(parser);
  parser.finalize();
  for (let i = 0; i < buffer.length; i++) yield buffer[i]!;
}

/**
 * Parses an async iterable of XML byte chunks and yields records assembled