Method Emit

internal/compiler/program.go:1633–1695

(ctx context.Context, options EmitOptions)

}

func (p *Program) Emit(ctx context.Context, options EmitOptions) *EmitResult {
	if tr := p.opts.Tracing; tr != nil {
		defer tr.Push(tracing.PhaseEmit, "emit", nil, true)()
	}

	if options.EmitOnly != EmitOnlyForcedDts {
		result := HandleNoEmitOnError(
			ctx,
			p,
			options.TargetSourceFile,
		)
		if result != nil || ctx.Err() != nil {
			return result
		}
	}

	newLine := p.Options().NewLine.GetNewLineCharacter()
	writerPool := &sync.Pool{
		New: func() any {
			return printer.NewTextWriter(newLine, 0)
		},
	}
	wg := core.NewWorkGroup(p.SingleThreaded())
	var emitters []*emitter
	sourceFiles := p.getSourceFilesToEmit(options.TargetSourceFile, options.EmitOnly == EmitOnlyForcedDts)

	for _, sourceFile := range sourceFiles {
		emitter := &emitter{
			writer:     nil,
			sourceFile: sourceFile,
			emitOnly:   options.EmitOnly,
			writeFile:  options.WriteFile,
			tr:         p.opts.Tracing,
		}
		emitters = append(emitters, emitter)
		wg.Queue(func() {
			host, done := newEmitHost(ctx, p, sourceFile)
			defer done()
			emitter.host = host

			// take an unused writer
			writer := writerPool.Get().(printer.EmitTextWriter)
			writer.Clear()

			// attach writer and perform emit
			emitter.writer = writer
			emitter.paths = outputpaths.GetOutputPathsFor(sourceFile, host.Options(), host, options.EmitOnly == EmitOnlyForcedDts)
			emitter.emit()
			emitter.writer = nil

			// put the writer back in the pool
			writerPool.Put(writer)
		})
	}

	// wait for emit to complete
	wg.RunAndWait()