Method drainFrames

app/src/utils/tauriStreamCapture.ts:525–559

()

    let draining = false;

    const drainFrames = async () => {
      draining = true;
      while (pendingFrame && isActive) {
        const bytes = pendingFrame;
        pendingFrame = null; // frames arriving during this decode overwrite the slot
        try {
          const bitmap = await createImageBitmap(new Blob([bytes], { type: 'image/jpeg' }));
          if (!isActive) { bitmap.close(); break; }

          if (!canvasSizeInitialized && bitmap.width > 0) {
            canvasClean.width = bitmap.width;
            canvasClean.height = bitmap.height;
            if (canvasPip) {
              canvasPip.width = bitmap.width;
              canvasPip.height = bitmap.height;
            }
            canvasSizeInitialized = true;
            Logger.info("TAURI_STREAM", `Video canvas adapted to ${bitmap.width}x${bitmap.height}`);
          }

          ctxClean.drawImage(bitmap, 0, 0);

          if (ctxPip && canvasPip) {
            ctxPip.drawImage(bitmap, 0, 0);
            if (this.pipOverlayDrawer) {
              this.pipOverlayDrawer(ctxPip, canvasPip.width, canvasPip.height);
            }
          }
          bitmap.close();
        } catch (e) {
          Logger.error("TAURI_STREAM", `Image decode error: ${e}`);
        }
      }
      draining = false;
    };

    frameChannel.onmessage = (frameData: FrameData) => {
      if (!isActive) return;