Function deferLiveThreadUpdate

desktop/runtime-host/live-thread-publisher.ts:89–100

(
  runtime: PiRuntime,
  options: { requireStreaming?: boolean | undefined } = {},
)

}

export function deferLiveThreadUpdate(
  runtime: PiRuntime,
  options: { requireStreaming?: boolean | undefined } = {},
) {
  cancelLiveThreadUpdate(runtime)
  const timer = setTimeout(() => {
    liveThreadUpdateTimers.delete(runtime)
    if (options.requireStreaming !== false && !runtime.session.isStreaming) return
    void publishThreadUpdate(runtime, 'update')
  }, 0)
  liveThreadUpdateTimers.set(runtime, timer)
}

export function scheduleLiveThreadUpdate(runtime: PiRuntime) {
  if (liveThreadUpdateTimers.has(runtime)) return