Function streamParseFile

packages/parser/src/index.ts:340–370

(
  filePath: string,
  callbacks: Omit<StreamParseOptions, 'filePath'>,
  formatId?: string
)

 * @param formatId 可选，指定格式 ID（用于 fallback 机制，跳过自动检测）
 */
export async function streamParseFile(
  filePath: string,
  callbacks: Omit<StreamParseOptions, 'filePath'>,
  formatId?: string
): Promise<void> {
  const { onProgress, onMeta, onMembers, onMessageBatch, onLog, batchSize = 5000, formatOptions } = callbacks

  // 根据是否指定 formatId 选择解析方式
  const generator = formatId
    ? parseFileWithFormat(formatId, { filePath, batchSize, formatOptions, onProgress, onLog })
    : parseFile({ filePath, batchSize, formatOptions, onProgress, onLog })

  for await (const event of generator) {
    switch (event.type) {
      case 'meta':
        onMeta(event.data)
        break
      case 'members':
        onMembers(event.data)
        break
      case 'messages':
        onMessageBatch(event.data)
        break
      case 'progress':
        onProgress(event.data)
        break
      case 'error':
        throw event.data
    }
  }
}