Class VideoEncoderPolyfill

src/video_encoder.ts:89–708

 * Corresponds to the WebCodecs VideoEncoder API.
 */
export class VideoEncoderPolyfill extends EventTarget {
	private init: VideoEncoderInit;
	private config: VideoEncoderConfig | null = null;
	private codecContext: CodecContext | null = null;
	private mutex = new AsyncMutex();
	private frame: Frame;
	private packet: Packet;
	private _encodeQueueSize = 0;
	private currentConfigId = 0;
	private chunkOutputted = false;
	private colorSpaceSet = false;
	private pendingFlushResolvers: Array<{ resolve: () => void; reject: (e: unknown) => void }> = [];
	private scaler: SoftwareScaleContext | null = null;
	private lastScalerKey: string | null = null;
	private dstFrame: Frame | null = null;

	private _state: VideoEncoder['state'] = 'unconfigured';
	/**
	 * The current state of the encoder: "unconfigured", "configured", or "closed".
	 */
	get state() {
		return this._state;
	}

	/**
	 * The number of pending encode operations.
	 */
	get encodeQueueSize() {
		return this._encodeQueueSize;
	}

	/**
	 * Event handler called when an encode operation completes and leaves the queue.
	 */
	ondequeue: ((this: VideoEncoder, ev: Event) => unknown) | null = null;

	/**
	 * Creates a new VideoEncoder.
	 */
	constructor(init: VideoEncoderInit) {
		super();

		if (!init.output || !init.error) {
			throw new TypeError('VideoEncoderInit requires \'output\' and \'error\' callbacks.');
		}

		this.init = init;
		this.frame = new Frame();
		this.frame.alloc();
		this.packet = new Packet();
		this.packet.alloc();
	}

	private static createCodecContext(config: VideoEncoderConfig) {
		const inferred = inferCodecFromCodecString(config.codec);
		if (!inferred) {
			throw new Error('Unsupported codec');
		}