Function corePipeline

ui/src/components/pipeline/pipeline.ts:33–53

(
  input: LoadingInput,
  ctx: PipelineContext,
)

export { initParsers } from './stages/parsing';

function* corePipeline(
  input: LoadingInput,
  ctx: PipelineContext,
): Generator<PipelineEvent> {
  const scanResult = yield* scanning(input, ctx);

  if (ctx.cancelled) return;

  const processingOutput = yield* processing(scanResult, ctx);

  if (ctx.cancelled) return;

  const finalResult = yield* resolving(processingOutput);

  yield {
    kind: 'done',
    phase: 'resolving',
    message: 'Pipeline complete',
    result: finalResult,
  };
}

export function* runPipeline(
  input: LoadingInput,